[−][src]Struct workpool::dynamic_pool::WaitHandle
WaitHandle provides a handle to wait for remaining items to finish processing.
Methods
impl<O> WaitHandle<O>[src]
pub fn set_concurrency_limit(&self, concurrency_limit: i64)[src]
Adjust the concurrency_limit. Only this many work items will be processed concurrently. If the pool is currently processing more than the new limit's amount of work the current work will finish processing until the amount of concurrenct work drops below the new threshold.
pub fn wait(&self) -> &O[src]
Wait for all input to be processed and return a reference to the output value.
Trait Implementations
impl<O> WaitHandle for WaitHandle<O>[src]
impl<O> Clone for WaitHandle<O>[src]
fn clone(&self) -> Self[src]
fn clone_from(&mut self, source: &Self)1.0.0[src]
Performs copy-assignment from source. Read more
impl<O: Debug> Debug for WaitHandle<O>[src]
Auto Trait Implementations
impl<O> Send for WaitHandle<O> where
O: Send + Sync,
O: Send + Sync,
impl<O> Sync for WaitHandle<O> where
O: Send + Sync,
O: Send + Sync,
Blanket Implementations
impl<T, U> Into for T where
U: From<T>, [src]
U: From<T>,
impl<T> ToOwned for T where
T: Clone, [src]
T: Clone,
impl<T> From for T[src]
impl<T, U> TryFrom for T where
U: Into<T>, [src]
U: Into<T>,
type Error = Infallible
The type returned in the event of a conversion error.
fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>[src]
impl<T> Borrow for T where
T: ?Sized, [src]
T: ?Sized,
impl<T> BorrowMut for T where
T: ?Sized, [src]
T: ?Sized,
fn borrow_mut(&mut self) -> &mut T[src]
impl<T, U> TryInto for T where
U: TryFrom<T>, [src]
U: TryFrom<T>,
type Error = <U as TryFrom<T>>::Error
The type returned in the event of a conversion error.
fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>[src]
impl<T> Any for T where
T: 'static + ?Sized, [src]
T: 'static + ?Sized,