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
impl<T, Queue> Executor<T> for ThreadPoolExecutor<T, Queue> where T: Task, Queue: TaskQueue<T>impl<T: Task> Executor<T> for SameThreadExecutorimpl<T, Queue> Executor<T> for ManualExecutor<T, Queue> where T: Task, Queue: TaskQueue<T>