workerpool

Overview ¶

Package workerpool provides a generic, tick-driven worker pool that repeatedly invokes an Executor on a fixed interval.

The pool spawns N concurrent workers that wake up on each tick interval and execute the handler. This is useful for periodic background jobs (e.g., cache refreshes, cleanup tasks) that should run concurrently without blocking each other. Execution timeouts are enforced per worker.

Basic usage:

executor := &MyExecutor{}
pool := workerpool.New(executor,
    workerpool.WithWorkerCount(3),
    workerpool.WithTickInterval(1*time.Minute),
    workerpool.WithExecutionTimeout(30*time.Second),
)
if err := pool.Start(ctx); err != nil {
    return err
}
defer pool.Stop()

Each worker runs independently; if one times out or fails, others continue executing. The pool prevents concurrent overlapping executions of the same worker (each waits for the previous to finish).