Struct wasmer_wasix::runtime::task_manager::tokio::TokioTaskManager

pub struct TokioTaskManager(_);

A task manager that uses tokio to spawn tasks.

Implementations

impl TokioTaskManager

pub fn new(rt: Handle) -> Self

pub fn runtime_handle(&self) -> Handle

pub fn set_shared(rt: Arc<Runtime>) -> Result<(), Error>

Allows the caller to set the shared runtime that will be used by other async processes within Wasmer

The shared runtime must be set before it is used and can only be set once otherwise this call will fail with an error.

pub fn shared() -> Self

Shared tokio VirtualTaskManager that is used by default.

This exists because a tokio runtime is heavy, and there should not be many independent ones in a process.

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() -> Pin<Box<dyn Future<Output = ()> + Send + 'static>> + Send + 'static> ) -> Result<(), WasiThreadError>

See VirtualTaskManager::task_shared.

fn runtime(&self) -> &Handle

See VirtualTaskManager::runtime.

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 runtime_enter<'g>(&'g self) -> Box<dyn Drop + 'g>

Enters a runtime context

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

Build a new Webassembly memory.