Struct task_exec_queue::LocalTaskExecQueue

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

Implementations

impl<Tx, G, D> LocalTaskExecQueue<Tx, G, D>

where Tx: Clone + Sink<(D, LocalTaskType)> + Unpin + 'static, G: Hash + Eq + Clone + Debug + '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, G, D>

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

pub fn workers(&self) -> usize

pub fn active_count(&self) -> isize

pub fn waiting_count(&self) -> isize

pub async fn completed_count(&self) -> isize

pub fn pending_wakers_count(&self) -> usize

pub fn waiting_wakers_count(&self) -> usize

pub async fn rate(&self) -> f64

pub fn is_full(&self) -> bool

pub fn is_active(&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 + 'static, G: Hash + Eq + Clone + Debug + '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.

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

Performs copy-assignment from source.