Versions in this module Expand all Collapse all v1 v1.1.5 Dec 22, 2023 v1.0.0 Dec 22, 2023 Changes in this version + func AttachPanicHandle(f func()) func() + func CheckGoroutineErr(errCtx context.Context) error + type Job func() + type Pool struct + JobQueue chan Job + func NewPool(numWorkers int, jobQueueLen int) *Pool + func (p *Pool) JobDone() + func (p *Pool) Release() + func (p *Pool) SendJob(job func()) + func (p *Pool) SendJobWithDeadline(job func(), t time.Time) bool + func (p *Pool) SendJobWithTimeout(job func(), t time.Duration) bool + func (p *Pool) WaitAll() + func (p *Pool) WaitCount(count int)
Go to main page