upool

Jan 4, 2022

Changes in this version

+ var ErrTaskPoolClosed error = errors.New("task_pool already closed")

+ type LogLevel uint8

+ const DebugLevel

+ const ErrorLevel

+ const FatalLevel

+ const InfoLevel

+ const PanicLevel

+ const WarnLevel

+ func (ll LogLevel) GetType() string

+ type TaskOption struct

+ IdleTime int

+ LogLevel LogLevel

+ RecoverHandler func(interface{})

type TaskPool

+ func NewPool(capacity uint64, options ...TaskOption) *TaskPool

+ func (tp *TaskPool) PutTask(task TaskHandler) error

+ func (tp *TaskPool) WaitAndClose()

Sep 13, 2021

Changes in this version

type TaskPool

+ func (tp *TaskPool) Wait() <-chan struct{}

May 6, 2021

Changes in this version

+ var ErrPutTaskTimeout error = errors.New("put task into taskpool timeout")

Apr 28, 2021

Changes in this version

+ var ErrUnavailable error = errors.New("taskpool unavailable")

Apr 25, 2021

Changes in this version

+ var ErrResizeDeltaInvalid error = errors.New("resize capacity with wrong delta number")

+ var ErrResizeExcuting error = errors.New("resize capacity is excuting now")

+ var ErrResizeUnable error = errors.New("resize capacity unable now")

+ type TaskHandler interface

+ Execute func()

+ type TaskPool struct

+ func NewTaskPool(max uint64) *TaskPool

+ func (tp *TaskPool) Close() bool

+ func (tp *TaskPool) GetImf() (uint64, uint64)

+ func (tp *TaskPool) Put(task TaskHandler)

+ func (tp *TaskPool) ResizeCap(delta int) error