Package de.aristaflow.adept2.util.threading.executor

Class UnlimitedPipelineExecutor<O>

java.lang.Object
java.util.concurrent.AbstractExecutorService
java.util.concurrent.ThreadPoolExecutor
de.aristaflow.adept2.util.threading.AFThreadPoolExecutor
de.aristaflow.adept2.util.threading.CachedThreadPoolExecutor
de.aristaflow.adept2.util.threading.executor.AbstractObjectSpecificExecutor<O,P,Queue<Runnable>>
de.aristaflow.adept2.util.threading.executor.AbstractPipeliningExecutor<O,O>
de.aristaflow.adept2.util.threading.executor.UnlimitedPipelineExecutor<O>
Type Parameters:
O - The type of object for which work is registered and which identifies a pipeline.
All Implemented Interfaces:
Executor, ExecutorService
public class UnlimitedPipelineExecutor<O> extends AbstractPipeliningExecutor<O,O>
A pipeline executor that has a separate pipeline for each registered object and therefore also no upper limit concerning the amount of pipelines as well as the amount of threads.

  • Constructor Details

    • UnlimitedPipelineExecutor

      @Deprecated(since="14.4.0", forRemoval=true) public UnlimitedPipelineExecutor(Adept2ThreadFactory threadFactory)
      Deprecated, for removal: This API element is subject to removal in a future version.
      Use UnlimitedPipelineExecutor(int, Adept2ThreadFactory) instead.
      Creates a new thread pool executor with one pipeline per registered object and no limit for the threads. The threads will stay idle for 60 seconds before they terminate.
      Parameters:
      threadFactory - The factory to use when the executor creates a new thread.

    • UnlimitedPipelineExecutor

      public UnlimitedPipelineExecutor(int maxPoolSize, Adept2ThreadFactory threadFactory)
      Creates a new thread pool executor with one pipeline per registered object and the designated maximum amount of threads. The threads will stay idle for 60 seconds before they terminate.
      Parameters:
      maxPoolSize - The maximum number of threads allowed in the pool. Set this to a sensible value (< Integer.MAX_VALUE).
      threadFactory - The factory to use when the executor creates a new thread.

  • Method Details

    • getIndexObjectFor

      protected O getIndexObjectFor(O object)
      Description copied from class: AbstractObjectSpecificExecutor
      Gets the object used for managing and executing runnables within this executor.
      Specified by:
      getIndexObjectFor in class AbstractObjectSpecificExecutor<O,O,Queue<Runnable>>
      Parameters:
      object - The object for which a runnable is registered.
      Returns:
      The object used for managing and executing runnables (registered for the designated object) within this executor.