Struct TokioTaskManager

pub struct TokioTaskManager { /* private fields */ }

Available on crate feature sys-thread only.

A task manager that uses tokio to spawn tasks.

Implementations

impl TokioTaskManager

pub fn new<I>(rt: I) -> Self

where I: Into<RuntimeOrHandle>,

pub fn runtime_handle(&self) -> Handle

pub fn pool_handle(&self) -> Arc<ThreadPool>

Trait Implementations

impl Clone for TokioTaskManager

fn clone(&self) -> TokioTaskManager

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for TokioTaskManager

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

Formats the value using the given formatter.

impl Default for TokioTaskManager

fn default() -> Self

Returns the “default value” for a type.

impl VirtualTaskManager for TokioTaskManager

fn sleep_now( &self, time: Duration, ) -> Pin<Box<dyn Future<Output = ()> + Send + Sync>>

See VirtualTaskManager::sleep_now.

fn task_shared( &self, task: Box<dyn FnOnce() -> BoxFuture<'static, ()> + Send + 'static>, ) -> Result<(), WasiThreadError>

See VirtualTaskManager::task_shared.

fn task_wasm(&self, task: TaskWasm<'_, '_>) -> Result<(), WasiThreadError>

See VirtualTaskManager::task_wasm.

fn task_dedicated( &self, task: Box<dyn FnOnce() + Send + 'static>, ) -> Result<(), WasiThreadError>

See VirtualTaskManager::task_dedicated.

fn thread_parallelism(&self) -> Result<usize, WasiThreadError>

See VirtualTaskManager::thread_parallelism.

fn build_memory( &self, store: &mut StoreMut<'_>, spawn_type: SpawnMemoryType<'_>, ) -> Result<Option<Memory>, WasiThreadError>

Build a new Webassembly memory.

fn spawn_with_module( &self, module: Module, task: Box<dyn FnOnce(Module) + Send + 'static>, ) -> Result<(), WasiThreadError>

Schedule a blocking task to run on the threadpool, explicitly transferring a Module to the task.