worker

type Pool interface {
	AddTask(t Task)
	AddTasks(t []Task)
	Start()
	StartWithWorkerCreator(f func() (Worker, error)) error
	Stop()
}

type PoolConfig struct {
	NumWorker int
	QueueSize int
}

type Task interface {
	WaitForResult() error
	Execute()
	ExecuteWithContext(ctx context.Context)
}

type Worker interface {
	SetQueue(chan Task)
	Start()
	Stop()
}