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 logicConsumer
to be applied to the elements enountered by aParallelProcedure
.static interface
ParallelProcedure.ThreadCountProvider
static interface
ParallelProcedure.ThreadTimeoutProvider
-
Method Summary