worker

type TaskWorker interface {
	WorkerCount() int

	SetCallback(func(int, interface{})) error
	SetSource(*queue.RingBuffer) error
	Invoke(interface{}) error

	Start()
	Close()
}