Struct timely::scheduling::activate::SyncActivations

pub struct SyncActivations { /* private fields */ }

A thread-safe handle to an Activations.

Implementations

impl SyncActivations

pub fn activate(&self, path: Vec<usize>) -> Result<(), SyncActivationError>

Unparks the task addressed by path and unparks the associated worker thread.

pub fn activate_batch<I>(&self, paths: I) -> Result<(), SyncActivationError>

where I: IntoIterator<Item = Vec<usize>>,

Unparks the tasks addressed by paths and unparks the associated worker thread.

This method can be more efficient than calling activate repeatedly, as it only unparks the worker thread after sending all of the activations.

Trait Implementations

impl Clone for SyncActivations

fn clone(&self) -> SyncActivations

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for SyncActivations

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

Formats the value using the given formatter.