Struct AgentPool 

pub struct AgentPool { /* private fields */ }

Controlled-parallelism executor for Agents. Clone-safe? No — use one pool per batch. Methods take &self so tasks can be spawned and consumed from different code paths concurrently.

Implementations

impl AgentPool

pub fn new() -> Self

pub fn batch_size(self, n: usize) -> Self

Maximum number of jobs running concurrently.

pub fn ordering(self, o: PoolStrategy) -> Self

Select how next() / drain() order results.

pub async fn spawn(&self, agent: Agent) -> JobId

Submit a pre-configured agent. Awaits a permit if at capacity.

pub async fn next(&self) -> Option<(JobId, Result<AgentOutput>)>

Yield the next completed job per the configured ordering. None when no jobs are pending and no buffered entries remain.

pub async fn drain(&self) -> Vec<(JobId, Result<AgentOutput>)>

Drain every currently pending job, yielding per the configured ordering.

Trait Implementations

impl Default for AgentPool

fn default() -> Self

Returns the “default value” for a type.