Struct TaskSupervisor 

pub struct TaskSupervisor { /* private fields */ }

Implementations

impl TaskSupervisor

pub fn new() -> Self

pub fn with_diagnostics(diagnostics: Arc<RuntimeDiagnosticSink>) -> Self

pub fn group(&self, name: impl Into<String>) -> TaskGroup

pub fn spawn_named<F>( &self, name: impl Into<String>, fut: F, ) -> OwnedTaskHandle<u64>

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

pub fn spawn_cancellable_named<F>( &self, name: impl Into<String>, fut: F, ) -> OwnedTaskHandle<u64>

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

pub fn spawn_local_named<F>( &self, name: impl Into<String>, fut: F, ) -> OwnedTaskHandle<u64>

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

pub fn spawn_local_cancellable_named<F>( &self, name: impl Into<String>, fut: F, ) -> OwnedTaskHandle<u64>

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

pub fn spawn_interval_until_named<F, Fut>( &self, name: impl Into<String>, time_effects: Arc<dyn PhysicalTimeEffects + Send + Sync>, interval: Duration, f: F, ) -> OwnedTaskHandle<u64>

where F: FnMut() -> Fut + Send + 'static, Fut: Future<Output = bool> + Send + 'static,

pub fn spawn_local_interval_until_named<F, Fut>( &self, name: impl Into<String>, time_effects: Arc<dyn PhysicalTimeEffects + Send + Sync>, interval: Duration, f: F, ) -> OwnedTaskHandle<u64>

where F: FnMut() -> Fut + 'static, Fut: Future<Output = bool> + 'static,

pub fn spawn_child<F>( &self, name: impl Into<String>, fut: F, ) -> OwnedTaskHandle<u64>

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

pub fn spawn_periodic<F, Fut>( &self, name: impl Into<String>, time_effects: Arc<dyn PhysicalTimeEffects + Send + Sync>, interval: Duration, f: F, ) -> OwnedTaskHandle<u64>

where F: FnMut() -> Fut + Send + 'static, Fut: Future<Output = bool> + Send + 'static,

pub fn request_cancellation(&self)

pub async fn wait_for_idle( &self, timeout: Duration, ) -> Result<(), TaskSupervisionError>

pub fn force_abort_remaining(&self) -> Result<(), TaskSupervisionError>

pub fn abort_remaining(&self) -> Result<(), TaskSupervisionError>

pub async fn shutdown_with_timeout( &self, timeout: Duration, ) -> Result<(), TaskSupervisionError>

pub async fn shutdown_gracefully( &self, timeout: Duration, ) -> Result<(), TaskSupervisionError>

pub fn shutdown(&self)

pub fn cancellation_token(&self) -> Arc<dyn CancellationToken>

pub fn active_tasks(&self) -> Vec<String>

Trait Implementations

impl Clone for TaskSupervisor

fn clone(&self) -> TaskSupervisor

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Default for TaskSupervisor

fn default() -> Self

Returns the “default value” for a type.

impl Drop for TaskSupervisor

fn drop(&mut self)

Executes the destructor for this type.

impl TaskSpawner for TaskSupervisor

fn spawn(&self, fut: BoxFuture<'static, ()>)

Spawn a background task.

fn spawn_cancellable( &self, fut: BoxFuture<'static, ()>, token: Arc<dyn CancellationToken>, )

Spawn a background task tied to a cancellation token.

fn spawn_local(&self, fut: LocalBoxFuture<'static, ()>)

Spawn a background task that may remain thread-local.

fn spawn_local_cancellable( &self, fut: LocalBoxFuture<'static, ()>, token: Arc<dyn CancellationToken>, )

Spawn a thread-local background task tied to a cancellation token.

fn cancellation_token(&self) -> Arc<dyn CancellationToken>

Return a cancellation token associated with this spawner.