Struct WorkerPool 

pub struct WorkerPool { /* private fields */ }

A pool of warm worker processes.

Implementations

impl WorkerPool

pub fn new(config: PoolConfig) -> Self

Create a new worker pool with the given configuration.

pub fn metrics(&self) -> &Arc<PoolMetrics>

Get a reference to the pool metrics.

pub async fn acquire( &self, sandbox_config: &SandboxConfig, ) -> Result<AcquiredWorker, SandboxError>

Acquire a worker from the pool, spawning a new one if necessary.

Returns None if the pool is shutting down or at capacity.

pub async fn release(&self, handle: AcquiredWorker, outcome: ReleaseOutcome)

Return a worker to the pool after use.

If the outcome is ReleaseOutcome::Fatal or the worker has exceeded max_uses, the worker is killed instead of returned to the idle pool.

pub async fn shutdown(&self)

Shut down the pool, killing all idle workers.

pub async fn reap_idle(&self)

Reap idle workers that have exceeded max_idle_time.

Call this periodically (e.g., every 10 seconds) from a background task. Preserves min_workers to avoid repeated cold starts.

pub async fn pre_warm( &self, config: &SandboxConfig, ) -> Result<usize, SandboxError>

Pre-warm the pool by spawning workers up to min_workers.

Each worker is spawned and given a Reset health check. Returns the number of workers successfully pre-warmed.

pub fn start_reap_task(self: &Arc<Self>, interval: Duration) -> JoinHandle<()>

Start a background task that periodically reaps idle workers.

The task runs until the returned JoinHandle is aborted or the pool shuts down.