Versions in this module Expand all Collapse all v1 v1.6.0 Apr 5, 2025 v1.4.0 Oct 6, 2024 Changes in this version + var ErrTaskPool = errors.New("naza.taskpool: fxxk") + func Go(task TaskFn, param ...interface{}) + func Init(modOptions ...ModOption) error + func KillIdleWorkers() + func NewWorker(p *pool) *worker + type DisposeType int + const DisposeTypeAsap + const DisposeTypeRunAllBlockTask + type ModOption func(option *Option) + type Option struct + InitWorkerNum int + MaxWorkerNum int + type Pool interface + Dispose func(t DisposeType) + GetCurrentStatus func() Status + Go func(task TaskFn, param ...interface{}) + KillIdleWorkers func() + func NewPool(modOptions ...ModOption) (Pool, error) + type Status struct + BlockTaskNum int + IdleWorkerNum int + TotalWorkerNum int + func GetCurrentStatus() Status + type TaskFn func(param ...interface{})
Go to main page