Struct fibers_tasque::DefaultCpuTaskQueue

pub struct DefaultCpuTaskQueue;

The default queue for executing CPU intensive tasks.

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

This is useful for executing heavy CPU intensive tasks (e.g., large data compression) without blocking main scheduler threads of fibers.

Methods

impl DefaultCpuTaskQueue

pub fn get(self) -> TaskQueue

Returns the task queue.

pub 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 TaskQueueExt for DefaultCpuTaskQueue

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

Executes the given function asynchronously.

impl Copy for DefaultCpuTaskQueue

impl Clone for DefaultCpuTaskQueue

fn clone(&self) -> DefaultCpuTaskQueue

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for DefaultCpuTaskQueue

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

Formats the value using the given formatter.