Versions in this module Expand all Collapse all v0 v0.1.0 Dec 16, 2021 Changes in this version + type Option func(opt *PoolOption) + func WithMaxTasksCount(cnt int) Option + func WithRecoverHandler(f func(interface{})) Option + func WithWorkerCount(count int) Option + func WithWorkerPoolSize(size int) Option + type Pool struct + func NewPool(options ...Option) *Pool + func NewSinglePool(options ...Option) *Pool + func (pool *Pool) Close() error + func (pool *Pool) Go(f func()) bool + func (pool *Pool) InProcess() int64 + type PoolFunc struct + func NewPoolFunc(fnk func(interface{}), options ...Option) *PoolFunc + func NewSinglePoolFunc(fnk func(interface{}), options ...Option) *PoolFunc + func (pool *PoolFunc) Call(arg interface{}) bool + func (pool *PoolFunc) Close() error + func (pool *PoolFunc) InProcess() int64 + type PoolOption struct + MaxTasksCount int + RecoverHandler func(interface{}) + WorkerCount int + WorkerPoolSize int + func (opt *PoolOption) PreparedWorkerCount() int + func (opt *PoolOption) TaskQueueSize() int Other modules containing this package github.com/demdxx/rpool/v2
Go to main page