Struct desync::scheduler::Scheduler

pub struct Scheduler { /* private fields */ }

The scheduler is used to schedule tasks onto a pool of threads

Implementations

impl Scheduler

pub fn new() -> Scheduler

Creates a new scheduler

(There’s usually only one scheduler)

pub fn set_max_threads(&self, max_threads: usize)

Changes the maximum number of threads this scheduler can spawn (existing threads are not despawned by this method)

pub fn despawn_threads_if_overloaded(&self)

Despawns threads if we’re running more than the maximum number

Must not be called from a scheduler thread (as it waits for the threads to despawn)

pub fn spawn_thread(&self)

Spawns a thread in this scheduler

pub fn create_job_queue(&self) -> Arc<JobQueue>

Creates a new job queue for this scheduler

pub fn async<TFn: 'static + Send + FnOnce()>(
    &self,
    queue: &Arc<JobQueue>,
    job: TFn
)

👎Deprecated since 0.3.0: please use desync instead

Schedules a job on this scheduler, which will run after any jobs that are already in the specified queue and as soon as a thread is available to run it.

pub fn desync<TFn: 'static + Send + FnOnce()>(
    &self,
    queue: &Arc<JobQueue>,
    job: TFn
)

Schedules a job on this scheduler, which will run after any jobs that are already in the specified queue and as soon as a thread is available to run it.

pub fn future<TFn, Item: 'static + Send>(
    &self,
    queue: &Arc<JobQueue>,
    job: TFn
) -> Box<dyn Future<Item = Item, Error = Canceled>>where
    TFn: 'static + Send + FnOnce() -> Item,

Schedules a job to run and returns a future for retrieving the result

pub fn after<'a, TFn, Item: 'static + Send, Error: 'static + Send, Res: 'static + Send, Fut: 'a + Future<Item = Item, Error = Error>>(
    &self,
    queue: &Arc<JobQueue>,
    after: Fut,
    job: TFn
) -> Box<dyn Future<Item = Res, Error = Error> + 'a>where
    TFn: 'static + Send + FnOnce(Result<Item, Error>) -> Result<Res, Error>,

Pauses a queue until a particular future has completed, before performing a task with the result of that future

pub fn suspend(
    &self,
    queue: &Arc<JobQueue>
) -> Box<dyn Future<Item = (), Error = Canceled>>

Requests that a queue be suspended once it has finished all of its active jobs

pub fn resume(&self, queue: &Arc<JobQueue>)

Resumes a queue that was previously suspended

pub fn sync<Result: Send, TFn: Send + FnOnce() -> Result>(
    &self,
    queue: &Arc<JobQueue>,
    job: TFn
) -> Result

Schedules a job on this scheduler, which will run after any jobs that are already in the specified queue. This function will not return until the job has completed.

Trait Implementations

impl Debug for Scheduler

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

Formats the value using the given formatter.