Struct task_exec_queue::TaskExecQueue

pub struct TaskExecQueue<Tx = Sender<((), TaskType)>, G = (), D = ()> { /* private fields */ }

Implementations

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

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

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

pub fn flush(&self) -> Flush<'_, Tx, G, D>

pub fn close(&self) -> Close<'_, Tx, G, 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 pending_wakers_count(&self) -> usize

pub fn waiting_wakers_count(&self) -> usize

pub 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> TaskExecQueue<Tx, G, ()>where Tx: Clone + Sink<((), TaskType)> + Unpin + Send + Sync + 'static, G: Hash + Eq + Clone + Debug + Send + Sync + 'static,

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

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

Trait Implementations

impl<Tx, G, D> Clone for TaskExecQueue<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.