Struct SendExecutor

pub struct SendExecutor { /* private fields */ }

A multi-threaded port-based executor for Fuchsia. Requires that tasks scheduled on it implement Send so they can be load balanced between worker threads.

Having a SendExecutor in scope allows the creation and polling of zircon objects, such as [fuchsia_async::Channel].

Panics

SendExecutor will panic on drop if any zircon objects attached to it are still alive. In other words, zircon objects backed by a SendExecutor must be dropped before it.

Implementations

impl SendExecutor

pub fn new(num_threads: u8) -> Self

Create a new multi-threaded executor.

pub fn set_worker_init( &mut self, worker_init: impl Fn() + Send + Sync + 'static, )

Set a new worker initialization callback. Will be invoked once at the start of each worker thread.

pub fn with_worker_init(self, worker_init: fn()) -> Self

Apply the worker initialization callback to an owned executor, returning the executor.

The initialization callback will be invoked once at the start of each worker thread.

pub fn port(&self) -> &Port

Get a reference to the Fuchsia zx::Port being used to listen for events.

pub fn run<F>(&mut self, future: F) -> F::Output

where F: Future + Send + 'static, F::Output: Send + 'static,

Run future to completion, using this thread and num_threads workers in a pool to poll active tasks.

Trait Implementations

impl Debug for SendExecutor

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

Formats the value using the given formatter.

impl Drop for SendExecutor

fn drop(&mut self)

Executes the destructor for this type.