Interface ParallelProcedure.LogicProvider<S,P extends Consumer<? super S>>
- All Known Implementing Classes:
public static interface ParallelProcedure.LogicProvider<S,P extends Consumer<? super S>>
P provideLogic()Provides the actual logic
Consumerto be applied to the elements enountered by a
This method always gets called by the actual worker thread that will use the provided logic, so that a call of
Thread.currentThread()inside the method will always return the logic executing thread. The intention is to give complex provider implementations a chance to get to know the executing thread before the logic is executed. It is however stronly discouraged to try and control the worker thread activity from outside as it can disturb or disrupt the actual thread management. E.g. any explicit interruption can cause the worker thread to be abolished and killed and the logic instance to be disposed.
- the logic instance to be used by a worker thread.
Signals the provider instance that the passed logic instance is no longer used and provides the cause for its disposal (e.g. an
InterruptedExceptionbecause the executing worker has been abolished)
An implementation of this method can be anything from a no-op to complex resource clean up.
logic- the not longer used logic that shall be disposed.
cause- the cause for the disposal.