Package de.aristaflow.adept2.util.threading

Class UnlimitedPipelineExecutor<O>

  • Type Parameters:
    O - The type of object for which work is registered and which identifies a pipeline.
    All Implemented Interfaces:
    Executor, ExecutorService
    @Deprecated
public class UnlimitedPipelineExecutor<O>
extends AbstractPipeliningExecutor<O,​O>
    Deprecated.
    Use UnlimitedPipelineExecutor instead.
    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.
    Author:
    Ulrich Kreher

    • Constructor Detail

      • UnlimitedPipelineExecutor

        public UnlimitedPipelineExecutor​(Adept2ThreadFactory threadFactory)
        Deprecated.
        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.

    • Method Detail

      • getPipelineFor

        protected O getPipelineFor​(O object)
        Deprecated.
        Gets the identifier determining the pipeline for the designated object accordingly to the limit of the number of pipelines. Returns the designated object.
        Specified by:
        getPipelineFor in class AbstractPipeliningExecutor<O,​O>
        Parameters:
        object - The object for which to determine the pipeline.
        Returns:
        The identifier determining the pipeline for the designated object.