Struct Executor

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

Implementations

impl<Tx, G, D> Executor<Tx, G, D>

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

pub fn spawn_with<T>(&mut 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, 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 rate(&self) -> f64

pub fn is_full(&self) -> bool

pub fn is_closed(&self) -> bool

pub fn is_flushing(&self) -> bool

impl<Tx, G> Executor<Tx, G, ()>

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

pub fn spawn<T>(&mut self, msg: T) -> Spawner<'_, T, Tx, G, ()>

where T: Future + Send + 'static, T::Output: Send + 'static,

Trait Implementations

impl<Tx, G, D> Clone for Executor<Tx, G, D>

where Tx: Clone,

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.