Struct compio_driver::AsyncifyPool

pub struct AsyncifyPool { /* private fields */ }

A thread pool to perform blocking operations in other threads.

Implementations

impl AsyncifyPool

pub fn new(thread_limit: usize, recv_timeout: Duration) -> Self

Create AsyncifyPool with thread number limit and channel receive timeout.

pub fn dispatch<D: Dispatchable>(&self, f: D) -> Result<(), DispatchError<D>>

Send a dispatchable, usually a closure, to another thread. Usually the user should not use it. When all threads are busy and thread number limit has been reached, it will return an error with the original dispatchable.

Trait Implementations

impl Clone for AsyncifyPool

fn clone(&self) -> AsyncifyPool

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for AsyncifyPool

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

Formats the value using the given formatter.