threadpool

Sep 11, 2025

Changes in this version

type Job

+ func FuncRunner(job func(ctx context.Context)) Job

Apr 19, 2025

Changes in this version

+ type OptionsFn func(*ThreadPool)

+ func WithLogger(logger *log.Logger) OptionsFn

type Pool

+ DispatchWithContext func(ctx context.Context, j Job) error

+ DispatchWithTimeout func(j Job, timeout time.Duration) bool

+ TryDispatch func(j Job) bool

type ThreadPool

+ func (t *ThreadPool) DispatchWithContext(ctx context.Context, j Job) error

+ func (t *ThreadPool) DispatchWithTimeout(j Job, timeout time.Duration) bool

+ func (t *ThreadPool) TryDispatch(j Job) bool

Mar 31, 2024

Changes in this version

+ const ErrInvalidQueueSize

+ const ErrInvalidWorkerCount

+ const ErrPoolAlreadyStarted

+ const ErrPoolNotStarted

+ type Job interface

+ Run func(ctx context.Context)

+ type Pool interface

+ Dispatch func(j Job)

+ Start func() error

+ Stop func() error

+ type ThreadPool struct

+ func NewThreadPool(workerCount int, queueSize int) (*ThreadPool, error)

+ func (t *ThreadPool) Dispatch(j Job)

+ func (t *ThreadPool) GetQueueCapacity() int

+ func (t *ThreadPool) GetQueueLen() int

+ func (t *ThreadPool) GetRequestCount() uint64

+ func (t *ThreadPool) GetWorkerCount() int

+ func (t *ThreadPool) Start(ctx context.Context) error

+ func (t *ThreadPool) Stop() error

+ type Worker struct

+ func NewWorker(jobQueue chan Job, ctx context.Context) *Worker

+ func (w *Worker) RequestCounter() uint64

+ func (w *Worker) Start(wg *sync.WaitGroup)

+ type WorkerGroup struct

+ func NewWorkerGroup(workerCount int, jobQueue chan Job, parentCtx context.Context) (*WorkerGroup, error)

+ func (w *WorkerGroup) RequestCount() uint64

+ func (w *WorkerGroup) Stop()