Struct rust_box::task_exec_queue::TaskExecQueue

pub struct TaskExecQueue<Tx = Sender<((), Box<dyn Future<Output = ()> + Unpin + Send + 'static, Global>)>, G = (), D = ()> { /* private fields */ }

Implementations

impl<Tx, G, D> TaskExecQueue<Tx, G, D>where
    Tx: 'static + Clone + Sink<(D, Box<dyn Future<Output = ()> + Unpin + Send + 'static, Global>)> + Unpin + Send + Sync,
    G: 'static + Hash + Eq + Clone + Debug + Send + Sync,

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

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

pub fn close(&self) -> Close<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 is_full(&self) -> bool

pub fn is_closed(&self) -> bool

pub fn is_flushing(&self) -> bool

impl<Tx, G> TaskExecQueue<Tx, G, ()>where
    Tx: 'static + Clone + Sink<((), Box<dyn Future<Output = ()> + Unpin + Send + 'static, Global>)> + Unpin + Send + Sync,
    G: 'static + Hash + Eq + Clone + Debug + Send + Sync,

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

Trait Implementations

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

fn clone(&self) -> TaskExecQueue<Tx, G, D>

Returns a copy of the value.

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

Performs copy-assignment from source.