Versions in this module Expand all Collapse all v1 v1.0.0 Sep 28, 2017 Changes in this version + type Job struct + Args []interface{} + Run Task + type Queue interface + type QueueType int + const ArrayBlockingQueue + const LinkedBlockingQueue + const PriorityBlockingQueue + const SynchronousQueue + type Scheduler interface + Add func(job Job) bool + Join func(t Task, args ...interface{}) bool + func Default() (s Scheduler) + func New(qType QueueType, queueCap, workerNum int) (s Scheduler, err error) + func NewBlocking(workerNum int) (s Scheduler, err error) + type Task func(args ...interface{})