Struct timely::scheduling::activate::SyncActivations

pub struct SyncActivations { /* fields omitted */ }

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.