Struct timely::scheduling::activate::Activations

pub struct Activations { /* private fields */ }

Allocation-free activation tracker.

Implementations

impl Activations

pub fn new(timer: Instant) -> Self

Creates a new activation tracker.

pub fn activate(&mut self, path: &[usize])

Activates the task addressed by path.

pub fn activate_after(&mut self, path: &[usize], delay: Duration)

Schedules a future activation for the task addressed by path.

pub fn advance(&mut self)

Discards the current active set and presents the next active set.

pub fn map_active(&self, logic: impl Fn(&[usize]))

Maps a function across activated paths.

pub fn for_extensions(&self, path: &[usize], action: impl FnMut(usize))

Sets as active any symbols that follow path.

pub fn sync(&self) -> SyncActivations

Constructs a thread-safe SyncActivations handle to this activator.

pub fn empty_for(&self) -> Option<Duration>

Time until next scheduled event.

This method should be used before putting a worker thread to sleep, as it indicates the amount of time before the thread should be unparked for the next scheduled activation.

Trait Implementations

impl Debug for Activations

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

Formats the value using the given formatter.