Package one.microstream.functional

Interface ParallelProcedure<E>

All Superinterfaces:

Consumer<E>

All Known Implementing Classes:

ParallelProcedure.Default

public interface ParallelProcedure<E>
extends Consumer<E>

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static class	ParallelProcedure.Default<E>	Sample implementation with a user defined number of maximum worker threads and a user defined timeout (in ms) after which one worker thread will be abolished.
static interface	ParallelProcedure.LogicProvider<S,P extends Consumer<? super S>>	Type providing the actual logic Consumer to be applied to the elements enountered by aParallelProcedure.
static interface	ParallelProcedure.ThreadCountProvider
static interface	ParallelProcedure.ThreadTimeoutProvider

Method Summary

Modifier and Type	Method	Description
void	accept(E element)	Applies a wrapped logic by delegating its execution to another thread.

Methods inherited from interface java.util.function.Consumer

andThen

Method Detail

accept

void accept(E element)

Applies a wrapped logic by delegating its execution to another thread.

Specified by:

accept in interface Consumer<E>

Parameters:

element - the element to have the logic applied to.