pooler

Apr 23, 2023

Changes in this version

type Pool

+ func (p *Pool) PrepareToWait()

+ func (p *Pool) Wait()

Apr 22, 2023

Changes in this version

type Pool

+ func (p *Pool) Done() <-chan struct{}

Mar 8, 2020

Changes in this version

type Pool

+ func (p *Pool) ActiveTasks() int

+ func (p *Pool) ConfiguredRoutines() int

+ func (p *Pool) MaxTasks() int

+ func (p *Pool) Resize(newGoroutines int32) error

Feb 24, 2020

Changes in this version

type Pool

+ func (p *Pool) ShutdownWithTimeout(timeout time.Duration) bool

Feb 24, 2020

Changes in this version

+ type CallbackFuncQueue func(task *Task)

+ type CallbackFuncQueueErr func(task *Task, err error)

+ type CallbackFuncTask func(routine int, task *Task)

+ type CallbackFuncTaskErr func(routine int, task *Task, err error)

+ type CallbackFuncWrk func(routine int)

+ type Config struct

+ MaxTasks int

+ Routines int

+ TaskCrashedCB CallbackFuncTaskErr

+ TaskDoneCB CallbackFuncTask

+ TaskDoneWithErrorCB CallbackFuncTaskErr

+ TaskQueuedCB CallbackFuncQueue

+ TaskQueuingErrorCB CallbackFuncQueueErr

+ TaskStartedCB CallbackFuncTask

+ WorkerCreatedCB CallbackFuncWrk

+ WorkerShutdownCB CallbackFuncWrk

+ func NewConfig(routines, maxTasks int) *Config

+ func (c *Config) OnTaskCrashed(fn CallbackFuncTaskErr) *Config

+ func (c *Config) OnTaskDone(fn CallbackFuncTask) *Config

+ func (c *Config) OnTaskDoneWithError(fn CallbackFuncTaskErr) *Config

+ func (c *Config) OnTaskQueued(fn CallbackFuncQueue) *Config

+ func (c *Config) OnTaskQueuingError(fn CallbackFuncQueueErr) *Config

+ func (c *Config) OnTaskStarted(fn CallbackFuncTask) *Config

+ func (c *Config) OnWorkerCreated(fn CallbackFuncWrk) *Config

+ func (c *Config) OnWorkerShutdown(fn CallbackFuncWrk) *Config

type Pool

+ func NewWithConfig(config *Config) (*Pool, error)

Feb 23, 2020

Changes in this version

+ type CallbackFunc func(routine int, task *Task, event Event, err error)

+ type Event int

+ const QueueError

+ const TaskCrashed

+ const TaskDone

+ const TaskDoneWithError

+ const TaskQueued

+ const TaskStarted

+ const WorkerCreated

+ const WorkerShutdown

+ type Pool struct

+ func New(routineNum int, maxTasks int) (pool *Pool)

+ func NewWithCallback(routineNum int, maxTasks int, cbFunc CallbackFunc) (pool *Pool)

+ func (p *Pool) ActiveWorkers() int

+ func (p *Pool) Enqueue(task Runnable) error

+ func (p *Pool) IsShuttingDown() bool

+ func (p *Pool) QueueLen() int

+ func (p *Pool) Shutdown()

+ type Runnable interface

+ CustomData func() interface{}

+ ID func() string

+ Run func(routine int) error

+ type Task struct