Struct WorkerPool 

pub struct WorkerPool { /* private fields */ }

Implementations

impl WorkerPool

pub fn new(n1: usize, n2: usize, n3: usize) -> Self

pub fn spawn<F, T>( &self, priority: Priority, f: F, ) -> impl Future<Output = ClResult<T>>

where F: FnOnce() -> T + Send + 'static, T: Send + 'static,

Submit a closure with arguments → returns a Future for the result

pub fn run<F, T>(&self, f: F) -> impl Future<Output = ClResult<T>>

where F: FnOnce() -> T + Send + 'static, T: Send + 'static,

pub fn run_immed<F, T>(&self, f: F) -> impl Future<Output = ClResult<T>>

where F: FnOnce() -> T + Send + 'static, T: Send + 'static,

pub fn run_slow<F, T>(&self, f: F) -> impl Future<Output = ClResult<T>>

where F: FnOnce() -> T + Send + 'static, T: Send + 'static,

pub fn try_run<F, T>(&self, f: F) -> impl Future<Output = ClResult<T>>

where F: FnOnce() -> ClResult<T> + Send + 'static, T: Send + 'static,

Like run, but flattens ClResult<ClResult<T>> into ClResult<T>. Use when the closure itself returns ClResult<T>.

pub fn try_run_immed<F, T>(&self, f: F) -> impl Future<Output = ClResult<T>>

where F: FnOnce() -> ClResult<T> + Send + 'static, T: Send + 'static,

Like run_immed, but flattens ClResult<ClResult<T>> into ClResult<T>. Use when the closure itself returns ClResult<T>.

pub fn try_run_slow<F, T>(&self, f: F) -> impl Future<Output = ClResult<T>>

where F: FnOnce() -> ClResult<T> + Send + 'static, T: Send + 'static,

Like run_slow, but flattens ClResult<ClResult<T>> into ClResult<T>. Use when the closure itself returns ClResult<T>.

Trait Implementations

impl Debug for WorkerPool

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

Formats the value using the given formatter.