Trait Executor 

pub trait Executor {
    type Task<T: Send + 'static>: TaskImpl<Output = T> + Send + 'static;

    // Required methods
    fn block_on<T, F: Future<Output = T>>(&self, f: F) -> T
       where Self: Sized;
    fn spawn<T: Send + 'static, F: Future<Output = T> + Send + 'static>(
        &self,
        f: F,
    ) -> Task<Self::Task<T>> 
       where Self: Sized;
    fn spawn_blocking<T: Send + 'static, F: FnOnce() -> T + Send + 'static>(
        &self,
        f: F,
    ) -> Task<Self::Task<T>> 
       where Self: Sized;
}

A common interface for spawning futures on top of an executor

Required Associated Types

type Task<T: Send + 'static>: TaskImpl<Output = T> + Send + 'static

The type representing the tasks the are returned when spawning a Future on the executor

Required Methods

fn block_on<T, F: Future<Output = T>>(&self, f: F) -> T

where Self: Sized,

Block on a future until completion

fn spawn<T: Send + 'static, F: Future<Output = T> + Send + 'static>( &self, f: F, ) -> Task<Self::Task<T>>

where Self: Sized,

Spawn a future and return a handle to track its completion.

fn spawn_blocking<T: Send + 'static, F: FnOnce() -> T + Send + 'static>( &self, f: F, ) -> Task<Self::Task<T>>

where Self: Sized,

Convert a blocking task into a future, spawning it on a decicated thread pool

Dyn Compatibility

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety", so this trait is not object safe.

Implementors

impl Executor for AsyncGlobalExecutor

type Task<T: Send + 'static> = AGETask<T>

impl Executor for Noop

type Task<T: Send + 'static> = NTask<T>

impl Executor for Smol

type Task<T: Send + 'static> = STask<T>

impl Executor for Tokio

type Task<T: Send + 'static> = TTask<T>

impl<E: Deref> Executor for E

where E::Target: Executor + Sized,

type Task<T: Send + 'static> = <<E as Deref>::Target as Executor>::Task<T>

impl<E: Executor, R: Reactor> Executor for RuntimeParts<E, R>

type Task<T: Send + 'static> = <E as Executor>::Task<T>

impl<RK: RuntimeKit> Executor for Runtime<RK>

type Task<T: Send + 'static> = <RK as Executor>::Task<T>