pool

type Collector struct {
	Work chan *Job // receives jobs to send to workers
	// contains filtered or unexported fields
}

type Job struct {
	Data    interface{}
	JobFunc JobFunc
}

type JobFunc func(id int64, data interface{})

type Queue struct {
	sync.Mutex
	// contains filtered or unexported fields
}

type Worker struct {
	ID            int64
	WorkerChannel chan chan *Job // used to communicate between dispatcher and workers
	Channel       chan *Job
	End           chan struct{}
	// contains filtered or unexported fields
}