Struct timely::scheduling::activate::SyncActivator

pub struct SyncActivator { /* private fields */ }

A thread-safe version of Activator.

Implementations

impl SyncActivator

pub fn new(path: &[usize], queue: SyncActivations) -> Self

Creates a new thread-safe activation handle.

pub fn activate(&self) -> Result<(), SyncActivationError>

Activates the associated path and unparks the associated worker thread.

Trait Implementations

impl ArcWake for SyncActivator

fn wake_by_ref(arc_self: &Arc<Self>)

Indicates that the associated task is ready to make progress and should be polled.

fn wake(self: Arc<Self>)

Indicates that the associated task is ready to make progress and should be polled.

impl Clone for SyncActivator

fn clone(&self) -> SyncActivator

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for SyncActivator

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

Formats the value using the given formatter.