Versions in this module Expand all Collapse all v1 v1.0.1 Mar 13, 2024 Changes in this version type JobQueue + func (q *JobQueue) Quit() + func (q *JobQueue) Run() (err error) v1.0.0 May 2, 2022 Changes in this version + const JobStatusDone + const JobStatusFailed + const JobStatusPending + const JobStatusRunning + var Version = "1.0.0" + type Job interface + Process func() + Status func(status int, err error) + func NewJob(task func(), status ...func(status int, err error)) Job + type JobQueue struct + func New(maxWorkers int) *JobQueue + func (q *JobQueue) AddJob(job Job) + func (q *JobQueue) Start() + func (q *JobQueue) Stop() + 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