Struct timely::scheduling::activate::SyncActivator

pub struct SyncActivator { /* private fields */ }

A thread-safe version of Activator.

Implementations

impl SyncActivator

pub fn new(path: Vec<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 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.