Struct task_exec_queue::LocalTaskExecQueue

pub struct LocalTaskExecQueue<Tx = SyncSender, G = (), D = ()> { /* private fields */ }

Implementations

impl<Tx, G, D> LocalTaskExecQueue<Tx, G, D>where
    Tx: Clone + Sink<(D, LocalTaskType)> + Unpin + Sync + 'static,
    G: Hash + Eq + Clone + Debug + Sync + 'static,

pub fn try_spawn_with<T>(
    &self,
    msg: T,
    name: D
) -> TryLocalSpawner<'_, T, Tx, G, D>where
    D: Clone,
    T: Future + 'static,
    T::Output: 'static,

pub fn spawn_with<T>(&self, msg: T, name: D) -> LocalSpawner<'_, T, Tx, G, D>where
    D: Clone,
    T: Future + 'static,
    T::Output: 'static,

pub fn flush(&self) -> LocalFlush<Tx, D>

pub fn close(&self) -> LocalClose<Tx, D>

pub fn workers(&self) -> usize

pub fn active_count(&self) -> isize

pub fn waiting_count(&self) -> isize

pub fn completed_count(&self) -> isize

pub fn rate(&self) -> f64

pub fn is_full(&self) -> bool

pub fn is_closed(&self) -> bool

pub fn is_flushing(&self) -> bool

impl<Tx, G> LocalTaskExecQueue<Tx, G, ()>where
    Tx: Clone + Sink<((), LocalTaskType)> + Unpin + Sync + 'static,
    G: Hash + Eq + Clone + Debug + Sync + 'static,

pub fn try_spawn<T>(&self, msg: T) -> TryLocalSpawner<'_, T, Tx, G, ()>where
    T: Future + 'static,
    T::Output: 'static,

pub fn spawn<T>(&self, msg: T) -> LocalSpawner<'_, T, Tx, G, ()>where
    T: Future + 'static,
    T::Output: 'static,

Trait Implementations

impl<Tx, G, D> Clone for LocalTaskExecQueue<Tx, G, D>where
    Tx: Clone,

fn clone(&self) -> Self

Returns a copy of the value.

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

Performs copy-assignment from source.