pool

type Collector struct {
	Work chan *Job
	// 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
	Channel       chan *Job
	End           chan struct{}
	// contains filtered or unexported fields
}