Struct ActivityCancellationHandle 

pub struct ActivityCancellationHandle { /* private fields */ }

Internal handle used by the worker runtime to signal cooperative cancellation.

Implementations

impl ActivityCancellationHandle

pub fn cancel(&self)

Signals cooperative cancellation to the handler-facing context.

The FLAG IS SET FIRST and the waiters woken second, and that order is load-bearing in both directions: a waiter woken by this call finds the flag already true (so ActivityContext::cancelled never wakes to a flag that has not landed yet), and a waiter that registered before the wake is woken by it (so the flag never lands with nobody told). Waking first and setting second would let a woken waiter read false, loop, and park forever on a notification that has already been spent.

notify_waiters runs only on the 0→1 transition because cancellation is signalled once: a second cancel has nothing new to say, and the waiters it would wake are the ones already returned by the flag.

Trait Implementations

impl Clone for ActivityCancellationHandle

fn clone(&self) -> ActivityCancellationHandle

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ActivityCancellationHandle

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

Formats the value using the given formatter.