Skip to main content

SyncStopper

Struct SyncStopper 

Source
pub struct SyncStopper { /* private fields */ }
Expand description

A cancellation primitive with Release/Acquire memory ordering.

Unlike Stopper, whose checks are Relaxed loads, SyncStopper guarantees that all writes before cancel() are visible to any clone that subsequently observes should_stop() == true.

Converts to StopToken via From/Into with zero overhead — the existing Arc is reused, not double-wrapped.

§Performance

On x86-64 an Acquire load is an ordinary load, so a check costs what a Stopper’s does. On aarch64 it is ldar on targets without RCpc (Linux, Windows, Android, iOS) and ldapr with it (macOS): on a Neoverse-N1, a compute-bound loop checking every 64 bytes measured 3–10% slower than with a Relaxed check (code placement alone moved the same loop by similar amounts), and under 1% at a check per KiB or in memory-bound loops (benchmarks/stopper-ordering-2026-10-06.md). On ARMv6-M and ARMv7-M each check also executes a dmb. In a StopToken it is checked through the vtable.

Implementations§

Source§

impl SyncStopper

Source

pub fn new() -> Self

Create a new synchronized stopper.

Source

pub fn cancelled() -> Self

Create a stopper that is already cancelled.

Source

pub fn cancel(&self)

Cancel with a Release swap.

All memory writes before a cancel() are visible to any clone that observes should_stop() == true after it, even when several threads cancel.

Source

pub fn is_cancelled(&self) -> bool

Check if cancelled with Acquire ordering.

If this returns true, all memory writes that happened before the corresponding cancel() call are guaranteed to be visible.

Trait Implementations§

Source§

impl Clone for SyncStopper

Source§

fn clone(&self) -> Self

Returns a duplicate of the value. Read more
1.0.0 (const: unstable) · Source§

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

Performs copy-assignment from source. Read more
Source§

impl Debug for SyncStopper

Source§

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

Formats the value using the given formatter. Read more
Source§

impl Default for SyncStopper

Source§

fn default() -> Self

Returns the “default value” for a type. Read more
Source§

impl From<SyncStopper> for StopToken

Reuses the SyncStopper’s Arc (no allocation); checks go through the vtable.

Source§

fn from(stopper: SyncStopper) -> Self

Converts to this type from the input type.
Source§

impl Stop for SyncStopper

Source§

fn check(&self) -> Result<(), StopReason>

Check if the operation should stop. Read more
Source§

fn should_stop(&self) -> bool

Returns true if the operation should stop. Read more
Source§

fn may_stop(&self) -> bool

Returns true if this stop can ever signal a stop. Read more

Auto Trait Implementations§

Blanket Implementations§

Source§

impl<T> Any for T
where T: 'static + ?Sized,

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
Source§

impl<T> CloneStop for T
where T: Stop + Clone + 'static,

Source§

impl<T> CloneToUninit for T
where T: Clone,

Source§

unsafe fn clone_to_uninit(&self, dest: *mut u8)

🔬This is a nightly-only experimental API. (clone_to_uninit)
Performs copy-assignment from self to dest. Read more
Source§

impl<T> DebouncedTimeoutExt for T
where T: Stop,

Source§

fn with_debounced_timeout(self, duration: Duration) -> DebouncedTimeout<Self>

Add a debounced timeout to this stop. Read more
Source§

fn with_debounced_deadline(self, deadline: Instant) -> DebouncedTimeout<Self>

Add a debounced timeout with an absolute deadline.
Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T, U> Into<U> for T
where U: From<T>,

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<T> StopExt for T
where T: Stop,

Source§

fn or<S: Stop>(self, other: S) -> OrStop<Self, S>

Combine this stop with another, stopping if either stops. Read more
Source§

fn into_boxed(self) -> BoxedStop
where Self: 'static,

👎Deprecated since 0.4.5:

use into_token(), whose StopToken checks the same way and is Clone

Convert this stop into a BoxedStop. Deprecated: use into_token(), whose StopToken checks the same way and is Clone.
Source§

fn into_token(self) -> StopToken
where Self: 'static,

Convert this stop into a shared, cloneable StopToken. Read more
Source§

fn child(&self) -> ChildStopper
where Self: Clone + 'static,

Create a child stop that inherits cancellation from this stop. Read more
Source§

impl<T> TimeoutExt for T
where T: Stop,

Source§

fn with_timeout(self, duration: Duration) -> WithTimeout<Self>

Add a timeout to this stop. Read more
Source§

fn with_deadline(self, deadline: Instant) -> WithTimeout<Self>

Add an absolute deadline to this stop. Read more
Source§

impl<T> ToOwned for T
where T: Clone,

Source§

type Owned = T

The resulting type after obtaining ownership.
Source§

fn to_owned(&self) -> T

Creates owned data from borrowed data, usually by cloning. Read more
Source§

fn clone_into(&self, target: &mut T)

Uses borrowed data to replace owned data, usually by cloning. Read more
Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = !

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, !>

Performs the conversion.
Source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.