Versions in this module Expand all Collapse all v1 v1.0.1 Jul 13, 2024 Changes in this version + var WorkerChannel = make(chan chan *Job) + type Collector struct + End chan bool + Work chan *Job + func StartDispatcher(workerCount int64) Collector + func (c Collector) GetStatistics() *JobStatistics + func (c Collector) Waiting() int + type Job struct + Data interface{} + JobFunc JobFunc + type JobFunc func(id int64, data interface{}) + type JobStatistics struct + Executing int64 + Total int64 + type Queue struct + func NewQueue() *Queue + func (e *Queue) Close() + func (e *Queue) Len() int + func (e *Queue) Pop() (v interface{}) + func (e *Queue) Push(v interface{}) + func (e *Queue) TryPop() (v interface{}, ok bool) + func (e *Queue) Wait() + type Worker struct + Channel chan *Job + End chan struct{} + ID int64 + WorkerChannel chan chan *Job + func (w *Worker) Start() + func (w *Worker) Stop()
Go to main page