Struct WorkerPool 

pub struct WorkerPool { /* private fields */ }

Executes tasks concurrently under a global concurrency limit.

Each task is run on its own Tokio task but must first acquire a permit from a shared Semaphore, which caps how many run at once. The pool also owns the retry loop, per-attempt timeout, and circuit-breaker gating so the executor’s scheduling loop stays simple.

Implementations

impl WorkerPool

pub fn new( concurrency: usize, retry: RetryPolicy, timeout: Option<Duration>, metrics: Arc<MetricsCollector>, ) -> Self

Create a pool allowing concurrency simultaneous tasks.

pub fn available_permits(&self) -> usize

Permits currently available (i.e. free concurrency slots).

pub fn spawn( &self, task: Arc<dyn Task>, ctx: Arc<Context>, breaker: Option<Arc<CircuitBreaker>>, ) -> JoinHandle<TaskResult>

Spawn task for execution, returning a handle to its eventual result.

breaker, if supplied, gates execution: when open, the task fails fast with TaskError::CircuitOpen without consuming an attempt.