Versions in this module Expand all Collapse all v1 v1.1.0 Jul 4, 2018 v1.0.0 Jun 21, 2018 Changes in this version + func Push(job Jober) + func Run(maxQueues, maxWorkers int) + func Terminate() + type Jober interface + Job func() + func NewJob(v interface{}, fn func(interface{})) Jober + type Queue struct + func NewQueue(maxQueues, maxWorkers int) *Queue + func (q *Queue) Push(job Jober) + func (q *Queue) Run() + func (q *Queue) Terminate() + type SyncJober interface + Error func() error + Wait func() <-chan interface{} + func NewSyncJob(v interface{}, fn func(interface{}) (interface{}, error)) SyncJober + type Worker interface + Start func() + Terminate func() + func NewWorker(pool chan<- chan Jober, done func()) Worker
Go to main page