pools

Nov 30, 2020

Changes in this version

type ThreadPool

+ func (tp *ThreadPool) NewThreadID() uint64

Aug 18, 2019

Changes in this version

+ const StatusRunning

+ const StatusStopped

+ const StatusStopping

+ func NewByteBufferPool() *sync.Pool

+ func NewByteSlicePool(size int) *sync.Pool

+ type DefaultTaskQueue struct

+ func (tq *DefaultTaskQueue) Clear()

+ func (tq *DefaultTaskQueue) Pop() Task

+ func (tq *DefaultTaskQueue) Push(t Task)

+ func (tq *DefaultTaskQueue) Size() int

+ type Task interface

+ HandleError func(e error)

+ Run func() error

+ type TaskQueue interface

+ Clear func()

+ Pop func() Task

+ Push func(t Task)

+ Size func() int

+ type ThreadPool struct

+ RegulationLock *sync.Mutex

+ TooFewCallback func()

+ TooFewThreshold int

+ TooManyCallback func()

+ TooManyThreshold int

+ func NewThreadPool() *ThreadPool

+ func NewThreadPoolWithQueue(q TaskQueue) *ThreadPool

+ func (tp *ThreadPool) AddTask(t Task)

+ func (tp *ThreadPool) JoinAll()

+ func (tp *ThreadPool) SetWorkerCount(count int, wait bool)

+ func (tp *ThreadPool) Status() string

+ func (tp *ThreadPool) WaitAll()

+ func (tp *ThreadPool) WorkerCount() int

+ type ThreadPoolWorker struct