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>

  • Constructor Details

  • Method Details

    • 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.