taskpool

Feb 8, 2024

Changes in this version

+ func Init(capacity int, opts ...Option)

Feb 2, 2024

Changes in this version

+ const DefaultExpiredDuration

+ const DefaultPoolCapacity

+ var ErrPoolIsFull = errors.New("pool is full")

+ var ErrPoolIsOverload = errors.New("pool is overload")

+ var ErrPoolIsReleased = errors.New("pool is released")

+ func Submit(ctx context.Context, task func()) error

+ type Option func(o *Options)

+ func WithMaxBlockingTasks(maxBlockingTasks int) Option

+ func WithNonBlocking() Option

+ type Options struct

+ ExpiredDuration time.Duration

+ MaxBlockingTasks int

+ Nonblocking bool

+ func NewOptions() *Options

+ func (o *Options) Apply(opts ...Option)

+ type Pool struct

+ func NewPool(capacity int, opts ...Option) (*Pool, error)

+ func (p *Pool) Cap() int

+ func (p *Pool) IsClosed() bool

+ func (p *Pool) Release()

+ func (p *Pool) Running() int

+ func (p *Pool) Submit(ctx context.Context, f func()) error

+ func (p *Pool) Waiting() int