Versions in this module Expand all Collapse all v1 v1.0.0 Nov 5, 2020 Changes in this version + func Push(job Jober) + func Run(maxCapacity, maxThread int) + func RunListQueue(maxThread int) + func Terminate() + type Jober interface + Job func() + func NewJob(v interface{}, fn func(interface{})) Jober + type ListQueue struct + func NewListQueue(maxThread int) *ListQueue + func NewListQueueWithMaxLen(maxThread, maxLen int) *ListQueue + func (q *ListQueue) Push(job Jober) + func (q *ListQueue) Run() + func (q *ListQueue) Terminate() + type Queue struct + func NewQueue(maxCapacity, maxThread int) *Queue + func (q *Queue) Push(job Jober) + func (q *Queue) Run() + func (q *Queue) Terminate() + type Queuer interface + Push func(job Jober) + Run func() + Terminate func() + type SyncJober interface + Error func() error + Wait func() <-chan interface{} + func NewSyncJob(v interface{}, fn func(interface{}) (interface{}, error)) SyncJober