Trait executors::Executor [] [src]

pub trait Executor<T: Task> {
    fn queued(&self) -> usize;
    fn execute_with_priority(&self, task: T, priority: usize) -> Future<T::Result, T::Error>;
    fn clear(&self);

    fn execute(&self, task: T) -> Future<T::Result, T::Error> { ... }
}

Abstraction over task execution

Required Methods

fn queued(&self) -> usize

Returns number of elements waiting in queue

fn execute_with_priority(&self, task: T, priority: usize) -> Future<T::Result, T::Error>

Add new task to be executed. Lower value in priority means faster execution. Returns a Future result.

fn clear(&self)

Clear any pending tasks

Provided Methods

fn execute(&self, task: T) -> Future<T::Result, T::Error>

Add new task to be executed with default priority std::usize::MAX / 2

Implementors