worker

type Pool interface {
	AddTask(t Task)
	AddTasks(t []Task)
	Start()
	Stop()
}

type PoolConfig struct {
	NumWorker int
	QueueSize int
}

type Task interface {
	WaitForResult() error
	// contains filtered or unexported methods
}