co

Sep 25, 2020

Changes in this version

+ func PoolJobs(jobs []Job, concurrency int, stopOnErr bool, ...)

+ func PoolJobsEx(jobs chan Job, maxConcurrency int, stopOnErr bool, ...)

+ type Job interface

+ Run func() (ret interface{}, err error)