Struct workpool::dynamic_pool::WaitHandle

pub struct WaitHandle<O> { /* private fields */ }

WaitHandle provides a handle to wait for remaining items to finish processing.

Implementations

impl<O> WaitHandle<O>

pub fn set_concurrency_limit(&self, concurrency_limit: i64)

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

Wait for all input to be processed and return a reference to the output value.

Trait Implementations

impl<O> Clone for WaitHandle<O>

fn clone(&self) -> Self

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<O: Debug> Debug for WaitHandle<O>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<O> WaitHandle for WaitHandle<O>

type Output = O

fn wait(&self) -> &Self::Output