Struct fibers_tasque::DefaultIoTaskQueue

pub struct DefaultIoTaskQueue;

The default queue for executing I/O intensive tasks.

This queue is built by the expression TaskQueueBuilder::new().queue_name("fibers_default_io").finish() at the program startup time.

Usually it is preferred to use libraries specialized for asynchronous I/O instead of this. But this may be useful, for example, for executing existing synchronous functions (e.g., read_dir) as asynchronously in a fibers context.

Methods

impl DefaultIoTaskQueue

fn get(&self) -> TaskQueue

Returns the task queue.

fn with<F, T>(&self, f: F) -> T where
    F: FnOnce(&TaskQueue) -> T, 

Passes the reference to the task queue to the given function and executes it.

Trait Implementations

impl Debug for DefaultIoTaskQueue

fn fmt(&self, __arg_0: &mut Formatter) -> Result

Formats the value using the given formatter.

impl Clone for DefaultIoTaskQueue

fn clone(&self) -> DefaultIoTaskQueue

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Copy for DefaultIoTaskQueue

impl TaskQueueExt for DefaultIoTaskQueue

fn async_call<F, T>(&self, f: F) -> AsyncCall<T> where
    F: FnOnce() -> T + Send + 'static,
    T: Send + 'static, 

Executes the given function asynchronously.