Versions in this module Expand all Collapse all v1 v1.0.1 Apr 12, 2022 Changes in this version + type WorkerPool struct + func NewWorkerPool(channelsize int) *WorkerPool + func (t *WorkerPool) GetPendingItemCount() int + func (t *WorkerPool) GetQSize() int + func (t *WorkerPool) Idle() bool + func (t *WorkerPool) PushItem(a interface{}) + func (t *WorkerPool) SetHandler(fn func(interface{})) + func (t *WorkerPool) SetMaxGoroutine(nMaxCount int) + func (t *WorkerPool) SetMaxIdleGoroutine(nMaxCount int) + func (t *WorkerPool) SetMaxIdleTime(d time.Duration)
Go to main page