Struct workpool::static_pool::StaticPool

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

StaticPool is a pool with a static concurrency limit.

Implementations

impl<I, W, R> StaticPool<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 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 StaticPool<I, W, R>where W: Worker<I> + Debug, R: Reducer<W::Output> + Debug,

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

Formats the value using the given formatter.

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

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