Uses of Class
de.aristaflow.adept2.util.threading.PipelineRunnable
-
Packages that use PipelineRunnable Package Description de.aristaflow.adept2.util.threading -
-
Uses of PipelineRunnable in de.aristaflow.adept2.util.threading
Fields in de.aristaflow.adept2.util.threading with type parameters of type PipelineRunnable Modifier and Type Field Description protected Collection<PipelineRunnable<P>>PipelineFlushRunnable. awaitDeprecated.All pipelines of which the termination needs to be awaited.protected Map<P,Pair<PipelineRunnable<P>,Queue<Runnable>>>AbstractPipeliningExecutor. pipelinesDeprecated.All existing pipelines and the corresponding runnables.protected Map<P,Pair<PipelineRunnable<P>,Queue<Runnable>>>PipelineRunnable. pipelinesDeprecated.The data structures containing all pipelines from which the current pipeline will be removed as soon as it is empty.Constructor parameters in de.aristaflow.adept2.util.threading with type arguments of type PipelineRunnable Constructor Description PipelineFlushRunnable(Runnable task, Collection<PipelineRunnable<P>> await, boolean abortedPending, AbstractPipeliningExecutor<?,P> executor, Logger logger)Deprecated.Creates a new runnable that executes an exclusive tasks without any pipeline running.PipelineRunnable(P pipelineId, Queue<Runnable> pipeline, Map<P,Pair<PipelineRunnable<P>,Queue<Runnable>>> pipelines, AtomicInteger terminate, Logger logger)Deprecated.Creates a new runnable that executes all the work present for a specific object (in a pipeline).
-