task

Nov 25, 2025

Changes in this version

+ func Join[T any](ctx context.Context, futures ...*Future[T]) ([]T, error)

+ type Future struct

+ func Submit[T any](r *Runner, fn func(ctx context.Context) (T, error)) (*Future[T], error)

+ func (f *Future[T]) Get(ctx context.Context) (T, error)

Nov 19, 2025

Changes in this version

+ var ErrQueueFull = errors.New("task: queue is full")

+ var ErrRunnerClosed = errors.New("task: runner is closed")

+ func DefaultConfig() *config

+ func Go(ctx context.Context, fn func(context.Context), handler ErrorHandler)

+ func Safely(ctx context.Context, fn func(context.Context), handler ErrorHandler)

+ type ErrorHandler func(ctx context.Context, p any)

+ type Option func(*config)

+ func WithErrorHandler(h ErrorHandler) Option

+ func WithMaxWorkers(n int) Option

+ func WithQueueSize(n int) Option

+ type Runner struct

+ func NewRunner(opts ...Option) *Runner

+ func (r *Runner) Start(ctx context.Context) error

+ func (r *Runner) Stats() Stats

+ func (r *Runner) Stop(ctx context.Context) error

+ func (r *Runner) Submit(task TaskFunc) error

+ func (r *Runner) SubmitAndWait(ctx context.Context, task TaskFunc) error

+ type Stats struct

+ ActiveWorkers int64

+ MaxWorkers int

+ QueueSize int

+ QueuedTasks int

+ TotalPanics uint64

+ TotalProcessed uint64

+ TotalRefused uint64

+ type TaskFunc func(ctx context.Context)