Struct Executor 

pub struct Executor {
    inner: Arc<SmolEx<'static>>,
}

A handle to a multi-threaded async executor.

karyon does not run the executor for you. The caller owns the runtime and is responsible for driving it. On tokio this is just a Runtime. On smol you must spin up worker threads yourself, e.g. via easy_parallel:

use std::sync::Arc;
use async_channel::unbounded;
use easy_parallel::Parallel;
use smol::{future, Executor as SmolEx};

let ex = Arc::new(SmolEx::new());
let (signal, shutdown) = unbounded::<()>();

let num_threads = std::thread::available_parallelism()
    .map(|n| n.get())
    .unwrap_or(1);

Parallel::new()
    .each(0..num_threads, |_| future::block_on(ex.run(shutdown.recv())))
    .finish(|| future::block_on(async {
        // your async main here
        drop(signal);
    }));

Pass ex.clone().into() to karyon APIs that take an Executor.

Fields

inner: Arc<SmolEx<'static>>

Implementations

impl Executor

pub fn spawn<T: Send + 'static>( &self, future: impl Future<Output = T> + Send + 'static, ) -> Task<T>

Trait Implementations

impl Clone for Executor

fn clone(&self) -> Executor

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl From<Arc<Executor<'static>>> for Executor

Available on crate feature smol only.

fn from(ex: Arc<Executor<'static>>) -> Executor

Converts to this type from the input type.

impl From<Executor<'static>> for Executor

Available on crate feature smol only.

fn from(ex: Executor<'static>) -> Executor

Converts to this type from the input type.