Struct SubAgentPool 

pub struct SubAgentPool { /* private fields */ }

Pool for managing subagent instances.

Implementations

impl SubAgentPool

pub fn new(max_concurrent: usize, max_depth: usize) -> Self

Create a new subagent pool with default history limit (1000 entries).

pub fn with_max_history( max_concurrent: usize, max_depth: usize, max_history: usize, ) -> Self

Create a new subagent pool with explicit history limit.

pub async fn spawn( &self, task: impl Into<String>, parent_id: Option<SubAgentId>, ) -> RuntimeResult<Arc<SubAgentHandle>>

Spawn a new subagent.

Errors

Returns an error if the maximum subagent depth is exceeded or concurrency limit is reached.

pub async fn release(&self, id: &SubAgentId)

Release a subagent from the active pool and move to history.

Releases the semaphore permit so another sub-agent can be spawned. The handle’s status should already be set (completed/failed/timed out) before calling this.

pub async fn stop(&self, id: &SubAgentId) -> Option<Arc<SubAgentHandle>>

Stop a specific subagent: cancel it and move to history.

pub async fn get(&self, id: &SubAgentId) -> Option<Arc<SubAgentHandle>>

Get active subagent by ID.

pub async fn list_active(&self) -> Vec<Arc<SubAgentHandle>>

List active subagents.

pub async fn active_count(&self) -> usize

Get count of active subagents.

pub fn available_permits(&self) -> usize

Get available capacity.

pub async fn can_spawn_child(&self, parent_id: &SubAgentId) -> bool

Check if a child can be spawned for the given parent without actually spawning.

Returns true if both depth limit and concurrency permit are available.

pub fn cancellation_token(&self) -> CancellationToken

Get the cancellation token for cooperative cancellation.

Sub-agent executors should select on this token in their run loop. Cancelling this token signals all sub-agents to stop cooperatively.

pub async fn cancel_all(&self)

Cancel all active subagents and move them to history.

Also cancels the cooperative cancellation token so in-flight sub-agents can observe the cancellation and stop gracefully.

pub async fn wait_for_completion(&self)

Wait until the active pool is empty.

pub async fn wait_for_completion_timeout(&self, timeout: Duration) -> bool

Wait until the active pool is empty, or the timeout expires.

Returns true if the pool drained before the timeout, false otherwise.

pub async fn get_children( &self, parent_id: &SubAgentId, ) -> Vec<Arc<SubAgentHandle>>

Get direct children of a parent subagent (from both active and completed).

pub async fn get_subtree( &self, parent_id: &SubAgentId, ) -> Vec<Arc<SubAgentHandle>>

Get all descendants of a parent subagent (BFS, from both active and completed).

pub async fn cancel_subtree(&self, parent_id: &SubAgentId) -> usize

Cancel all active descendants of a parent subagent and move them to history.

Returns the number of subagents cancelled.

pub async fn history(&self) -> Vec<Arc<SubAgentHandle>>

Get completed subagents history.

pub async fn clear_history(&self)

Clear completed history.

pub async fn stats(&self) -> SubAgentPoolStats

Get pool statistics.

Trait Implementations

impl Debug for SubAgentPool

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.