Struct rust_box::task_exec_queue::LocalTaskExecQueue
source · [−]pub struct LocalTaskExecQueue<Tx = SyncSender, G = (), D = ()> { /* private fields */ }Implementations
sourceimpl<Tx, G, D> LocalTaskExecQueue<Tx, G, D>where
Tx: 'static + Clone + Sink<(D, Box<dyn Future<Output = ()> + Unpin + 'static, Global>)> + Unpin + Sync,
G: 'static + Hash + Eq + Clone + Debug + Sync,
impl<Tx, G, D> LocalTaskExecQueue<Tx, G, D>where
Tx: 'static + Clone + Sink<(D, Box<dyn Future<Output = ()> + Unpin + 'static, Global>)> + Unpin + Sync,
G: 'static + Hash + Eq + Clone + Debug + Sync,
pub fn spawn_with<T>(&mut self, msg: T, name: D) -> LocalSpawner<'_, T, Tx, G, D>ⓘNotable traits for LocalSpawner<'_, Item, Tx, G, D>impl<Item, Tx, G, D> Future for LocalSpawner<'_, Item, Tx, G, D>where
Item: 'static + Future,
<Item as Future>::Output: 'static,
Tx: 'static + Clone + Unpin + Sink<(D, Box<dyn Future<Output = ()> + Unpin + 'static, Global>)> + Sync,
G: 'static + Hash + Eq + Clone + Debug + Sync, type Output = Result<(), Error<Item>>;where
D: Clone,
T: 'static + Future,
<T as Future>::Output: 'static,
Item: 'static + Future,
<Item as Future>::Output: 'static,
Tx: 'static + Clone + Unpin + Sink<(D, Box<dyn Future<Output = ()> + Unpin + 'static, Global>)> + Sync,
G: 'static + Hash + Eq + Clone + Debug + Sync, type Output = Result<(), Error<Item>>;
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 is_full(&self) -> bool
pub fn is_closed(&self) -> bool
pub fn is_flushing(&self) -> bool
sourceimpl<Tx, G> LocalTaskExecQueue<Tx, G, ()>where
Tx: 'static + Clone + Sink<((), Box<dyn Future<Output = ()> + Unpin + 'static, Global>)> + Unpin + Sync,
G: 'static + Hash + Eq + Clone + Debug + Sync,
impl<Tx, G> LocalTaskExecQueue<Tx, G, ()>where
Tx: 'static + Clone + Sink<((), Box<dyn Future<Output = ()> + Unpin + 'static, Global>)> + Unpin + Sync,
G: 'static + Hash + Eq + Clone + Debug + Sync,
pub fn spawn<T>(&mut self, msg: T) -> LocalSpawner<'_, T, Tx, G, ()>ⓘNotable traits for LocalSpawner<'_, Item, Tx, G, D>impl<Item, Tx, G, D> Future for LocalSpawner<'_, Item, Tx, G, D>where
Item: 'static + Future,
<Item as Future>::Output: 'static,
Tx: 'static + Clone + Unpin + Sink<(D, Box<dyn Future<Output = ()> + Unpin + 'static, Global>)> + Sync,
G: 'static + Hash + Eq + Clone + Debug + Sync, type Output = Result<(), Error<Item>>;where
T: 'static + Future,
<T as Future>::Output: 'static,
Item: 'static + Future,
<Item as Future>::Output: 'static,
Tx: 'static + Clone + Unpin + Sink<(D, Box<dyn Future<Output = ()> + Unpin + 'static, Global>)> + Sync,
G: 'static + Hash + Eq + Clone + Debug + Sync, type Output = Result<(), Error<Item>>;
Trait Implementations
sourceimpl<Tx, G, D> Clone for LocalTaskExecQueue<Tx, G, D>where
Tx: Clone,
impl<Tx, G, D> Clone for LocalTaskExecQueue<Tx, G, D>where
Tx: Clone,
sourcefn clone(&self) -> LocalTaskExecQueue<Tx, G, D>
fn clone(&self) -> LocalTaskExecQueue<Tx, G, D>
Returns a copy of the value. Read more
1.0.0 · sourcefn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source. Read moreAuto Trait Implementations
impl<Tx = SyncSender, G = (), D = ()> !RefUnwindSafe for LocalTaskExecQueue<Tx, G, D>
impl<Tx = SyncSender, G = (), D = ()> !Send for LocalTaskExecQueue<Tx, G, D>
impl<Tx = SyncSender, G = (), D = ()> !Sync for LocalTaskExecQueue<Tx, G, D>
impl<Tx, G, D> Unpin for LocalTaskExecQueue<Tx, G, D>where
D: Unpin,
Tx: Unpin,
impl<Tx = SyncSender, G = (), D = ()> !UnwindSafe for LocalTaskExecQueue<Tx, G, D>
Blanket Implementations
sourceimpl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
const: unstable · sourcefn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more