Package one.microstream.functional

Class ParallelProcedure.LogicProvider.SingletonLogic<S,P extends Consumer<? super S>>

java.lang.Object

one.microstream.functional.ParallelProcedure.LogicProvider.SingletonLogic<S,P>

All Implemented Interfaces:

ParallelProcedure.LogicProvider<S,P>

Enclosing interface:

ParallelProcedure.LogicProvider<S,P extends Consumer<? super S>>

public static final class ParallelProcedure.LogicProvider.SingletonLogic<S,P extends Consumer<? super S>>
extends Object
implements ParallelProcedure.LogicProvider<S,P>

Nested Class Summary

Nested classes/interfaces inherited from interface one.microstream.functional.ParallelProcedure.LogicProvider

ParallelProcedure.LogicProvider.SingletonLogic<S,P extends Consumer<? super S>>

Constructor Summary

Constructors

Constructor	Description
SingletonLogic(P logic)

Method Summary

Modifier and Type	Method	Description
void	disposeLogic(P logic, Throwable cause)	Signals the provider instance that the passed logic instance is no longer used and provides the cause for its disposal (e.g.
P	provideLogic()	Provides the actual logic Consumer to be applied to the elements enountered by aParallelProcedure.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

SingletonLogic

public SingletonLogic(P logic)

Method Detail

provideLogic

public P provideLogic()

Description copied from interface: ParallelProcedure.LogicProvider

Provides the actual logic Consumer to be applied to the elements enountered by aParallelProcedure.

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.

Specified by:

provideLogic in interface ParallelProcedure.LogicProvider<S,P extends Consumer<? super S>>

Returns:

the logic instance to be used by a worker thread.

disposeLogic

public void disposeLogic(P logic,
                         Throwable cause)

Description copied from interface: ParallelProcedure.LogicProvider

Signals the provider instance that the passed logic instance is no longer used and provides the cause for its disposal (e.g. an InterruptedException because the executing worker has been abolished)

An implementation of this method can be anything from a no-op to complex resource clean up.

Specified by:

disposeLogic in interface ParallelProcedure.LogicProvider<S,P extends Consumer<? super S>>

Parameters:

logic - the not longer used logic that shall be disposed.

cause - the cause for the disposal.