Struct TaskHandler 

pub struct TaskHandler {
    task: Task<()>,
    stop_signal: Arc<CondWait>,
    cancel_flag: Arc<CondWait>,
}

TaskHandler

Fields

task: Task<()>

stop_signal: Arc<CondWait>

Per-task stop signal. Signaling it makes the task stop and run its callback with Cancelled.

cancel_flag: Arc<CondWait>

Set once the task has finished running its callback.

Implementations

impl TaskHandler

fn new<T, Fut, CallbackF, CallbackFut>( ex: Executor, fut: Fut, callback: CallbackF, group: Weak<Inner>, id: usize, ) -> TaskHandler

where T: Send + Sync + 'static, Fut: Future<Output = T> + Send + 'static, CallbackF: FnOnce(TaskResult<T>) -> CallbackFut + Send + 'static, CallbackFut: Future<Output = ()> + Send + 'static,

Creates a new task handler

fn detach(self)

Detaches the task, so dropping the handler does not cancel it.

async fn cancel(self)

Cancels the task: tells it to stop, waits for its callback to run, then aborts whatever is left.