Enum Scheduler

pub enum Scheduler<HostType: Host> {
    ThreadPerHost(ThreadPerHostSched<HostType>),
    ThreadPerCore(ThreadPerCoreSched<HostType>),
}

A wrapper for different host schedulers. It would have been nice to make this a trait, but would require support for GATs.

Variants

ThreadPerHost(ThreadPerHostSched<HostType>)

ThreadPerCore(ThreadPerCoreSched<HostType>)

Implementations

impl<HostType: Host> Scheduler<HostType>

pub fn parallelism(&self) -> usize

The maximum number of threads that will ever be run in parallel. The number of threads created by the scheduler may be higher.

pub fn scope<'scope>( &'scope mut self, f: impl for<'a, 'b> FnOnce(SchedulerScope<'a, 'b, 'scope, HostType>) + 'scope, )

Create a scope for any task run on the scheduler. The current thread will block at the end of the scope until the task has completed.

pub fn join(self)

Join all threads started by the scheduler.