Struct TerminatableTask 

pub struct TerminatableTask { /* private fields */ }

Implementations

impl TerminatableTask

pub fn create_cancellation_token() -> CancellationToken

pub fn spawn<F, T>( rt: ZRuntime, future: F, token: CancellationToken, ) -> TerminatableTask

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

Spawns a task that can be later terminated by TerminatableTask::terminate(). Prior to termination attempt the specified cancellation token will be cancelled.

pub fn spawn_abortable<F, T>(rt: ZRuntime, future: F) -> TerminatableTask

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

Spawns a task that can be later aborted by TerminatableTask::terminate().

pub fn terminate(&mut self, timeout: Duration) -> bool

Attempts to terminate the task. Returns true if task completed / aborted within timeout duration, false otherwise.

pub async fn terminate_async(&mut self)

Async version of TerminatableTask::terminate().

Trait Implementations

impl Drop for TerminatableTask

fn drop(&mut self)

Executes the destructor for this type.