Struct BackgroundMaintenanceQueue 

pub struct BackgroundMaintenanceQueue { /* private fields */ }

Bounded queue for post-turn maintenance that can be flushed by eval and shutdown paths.

Implementations

impl BackgroundMaintenanceQueue

pub fn new(max_tasks: usize) -> Self

Creates a queue with a positive task limit.

pub fn len(&self) -> usize

Returns the number of tracked tasks that have not been flushed yet.

pub fn is_empty(&self) -> bool

Returns true when no tracked tasks remain.

pub fn is_full(&self) -> bool

Returns true when the queue cannot accept another tracked task.

pub fn spawn<F>( &self, key: Option<MaintenanceSequenceKey>, future: F, ) -> Result<()>

where F: Future<Output = Result<()>> + Send + 'static,

Spawns a background task and applies per-key ordering when a key is supplied.

pub async fn flush_all(&self) -> Result<()>

Waits for all tracked background tasks to complete.

pub async fn flush_scope(&self, scope_id: &str) -> Result<()>

Waits for tasks with the requested scope identifier and keeps unrelated work queued.

pub async fn flush_purpose(&self, purpose: RuntimeTaskPurpose) -> Result<()>

Waits for tasks with the requested purpose and keeps unrelated work queued.

pub async fn flush_scope_purpose( &self, scope_id: &str, purpose: RuntimeTaskPurpose, ) -> Result<()>

Waits for tasks with the requested scope and purpose.

Trait Implementations

impl Default for BackgroundMaintenanceQueue

fn default() -> Self

Returns the “default value” for a type.