Versions in this module Expand all Collapse all v1 v1.0.0 Feb 21, 2023 Changes in this version + type Job interface + Process func() + type JobQueue struct + func NewJobQueue(maxWorkers int) *JobQueue + func (q *JobQueue) Start() + func (q *JobQueue) Stop() + func (q *JobQueue) Stopped() bool + func (q *JobQueue) Submit(job Job) + type Worker struct + func NewWorker(readyPool chan chan Job, done *sync.WaitGroup) *Worker + func (w *Worker) Start() + func (w *Worker) Stop()
Go to main page