Struct workpool::dynamic_pool::DynamicPool

pub struct DynamicPool<I, W, R>where
    W: Worker<I>,
    R: Reducer<W::Output>,{ /* private fields */ }

DynamicPool is a Pool that can dynamically adjust the number of threads at runtime.

Implementations

impl<I, W, R> DynamicPool<I, W, R>where I: Send + 'static, W: Worker<I> + Send + Sync + 'static, W::Output: Send, R: Reducer<W::Output> + Send + 'static, R::Output: Send + Sync,

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 add(&self, input: I)

Add a work item to be done by the pool.

pub fn wait_handle(self) -> WaitHandle<R::Output>

Return a wait handle. This indicates that no new work will be added to the pool and wait() can be invoked on the returned handle to wait for all input to be processed and retrieve the output value.

pub fn wait(self) -> R::Output

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

Trait Implementations

impl<I: Debug, W, R> Debug for DynamicPool<I, W, R>where W: Worker<I> + Debug, R: Reducer<W::Output> + Debug, R::Output: Debug,

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

Formats the value using the given formatter.

impl<I, W, R> Pool<I> for DynamicPool<I, W, R>where W: Worker<I>, R: Reducer<W::Output>,

type Output = <R as Reducer<<W as Worker<I>>::Output>>::Output

type WaitHandle = WaitHandle<<R as Reducer<<W as Worker<I>>::Output>>::Output>

fn add(&self, input: I)

fn wait_handle(self) -> Self::WaitHandle

fn wait(self) -> R::Output