Trait Scheduler

pub trait Scheduler {
    // Required method
    fn activations(&self) -> Rc<RefCell<Activations>>;

    // Provided methods
    fn activator_for(&self, path: Rc<[usize]>) -> Activator { ... }
    fn sync_activator_for(&self, path: Vec<usize>) -> SyncActivator { ... }
}

Methods for types which schedule fibers.

Required Methods

fn activations(&self) -> Rc<RefCell<Activations>>

Provides a shared handle to the activation scheduler.

Provided Methods

fn activator_for(&self, path: Rc<[usize]>) -> Activator

Constructs an Activator tied to the specified operator address.

fn sync_activator_for(&self, path: Vec<usize>) -> SyncActivator

Constructs a SyncActivator tied to the specified operator address.

Implementors

impl<A: Allocate> Scheduler for Worker<A>

impl<G, T> Scheduler for Child<'_, G, T>

where G: ScopeParent, T: Timestamp + Refines<G::Timestamp>,