Uses of Interface
de.aristaflow.adept2.util.threading.executor.ObjectRunnable

Packages that use ObjectRunnable

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

Uses of ObjectRunnable in de.aristaflow.adept2.util.threading.executor

Classes in de.aristaflow.adept2.util.threading.executor that implement ObjectRunnable

Modifier and Type	Class	Description
class	AbstractObjectRunnable<O1,O2,R>	An abstract implementation for an ObjectRunnable including some lifecycle management like being active and termination.
class	ObjectOneWorkRunnable<O,R extends AbstractObjectOneWorkExecutor.RuntimeData>	A runnable for having exactly one runnable per object.
class	PipelineRunnable<O,P>	A runnable that executes all runnables that are present for a specific object.
class	ScheduledObjectOneWorkRunnable<O>	A runnable that will enqueue a delayed object runnable as soon as the delay elapsed.

Fields in de.aristaflow.adept2.util.threading.executor with type parameters of type ObjectRunnable

Modifier and Type	Field	Description
protected Collection<ObjectRunnable<?,O2>>	ObjectSpecificFlushCallable.await	All pipelines of which the termination needs to be awaited.
protected Map<O2,Pair<ObjectRunnable<O1,O2>,R>>	AbstractObjectRunnable.objects	The data structures containing all objects and the corresponding work.
protected Map<O2,Pair<ObjectRunnable<O1,O2>,R>>	AbstractObjectSpecificExecutor.objects	All managed objects, their runnables as well as their runtime data.

Methods in de.aristaflow.adept2.util.threading.executor that return ObjectRunnable

Modifier and Type	Method	Description
protected ObjectRunnable<O,O>	AbstractObjectOneWorkExecutor.addRunnable(O registeredObject, O indexObject, Runnable task)
protected abstract ObjectRunnable<O1,O2>	AbstractObjectSpecificExecutor.addRunnable(O1 registeredObject, O2 indexObject, Runnable task)	Adds the designated runnable for the designated object and index object to this executor.
protected ObjectRunnable<O,P>	AbstractPipeliningExecutor.addRunnable(O registeredObject, P indexObject, Runnable task)
protected ObjectRunnable<O,O>	ScheduledObjectOneWorkExecutor.addRunnable(O registeredObject, O indexObject, Runnable task)

Method parameters in de.aristaflow.adept2.util.threading.executor with type arguments of type ObjectRunnable

Modifier and Type	Method	Description
protected <T> Pair<Future<T>,Map<O,R>>	AbstractObjectOneWorkExecutor.cancelAndFlush(boolean shutdownRequest, Map<O,R> pending, Callable<T> task, Collection<ObjectRunnable<O,O>> objectRunnables)
protected abstract <T> Pair<Future<T>,Map<O2,R>>	AbstractObjectSpecificExecutor.cancelAndFlush(boolean shutdownRequest, Map<O2,R> pending, Callable<T> task, Collection<ObjectRunnable<O1,O2>> objectRunnables)	Cancels the designated pending work (if appropriate), flushes (i. e. waits for or aborts the designated runnables) and executes the designated task.
protected <T> Pair<Future<T>,Map<P,Queue<Runnable>>>	AbstractPipeliningExecutor.cancelAndFlush(boolean shutdownRequest, Map<P,Queue<Runnable>> pending, Callable<T> task, Collection<ObjectRunnable<O,P>> objectRunnables)
protected <T> Pair<Future<T>,Map<O,ScheduledObjectOneWorkExecutor.ScheduledRuntimeData>>	ScheduledObjectOneWorkExecutor.cancelAndFlush(boolean shutdownRequest, Map<O,ScheduledObjectOneWorkExecutor.ScheduledRuntimeData> pending, Callable<T> task, Collection<ObjectRunnable<O,O>> objectRunnables)
protected void	ScheduledObjectOneWorkExecutor.enqueueDelayedRunnable(O registeredObject, O indexObject, Pair<ObjectRunnable<O,O>,ScheduledObjectOneWorkExecutor.ScheduledRuntimeData> pair)	Removes the delayed runnable from the designated scheduled runtime data for the designated (registered and index) object and adds it as normal pending work.

Constructor parameters in de.aristaflow.adept2.util.threading.executor with type arguments of type ObjectRunnable

Constructor	Description
AbstractObjectRunnable(O1 registeredObject, O2 indexObject, Map<O2,Pair<ObjectRunnable<O1,O2>,R>> objects, AtomicInteger terminate, Logger logger)	Creates a new runnable for the designated object.
ObjectSpecificFlushCallable(Callable<T> task, Collection<ObjectRunnable<?,O2>> await, boolean abortedPending, AbstractObjectSpecificExecutor<?,O2,?> executor, Logger logger)	Creates a new runnable that executes an exclusive tasks without any object work running.
PipelineRunnable(O object, P pipelineId, Queue<Runnable> pipeline, Map<P,Pair<ObjectRunnable<O,P>,Queue<Runnable>>> pipelines, AtomicInteger terminate, Logger logger)	Creates a new runnable that executes all the work present for a specific object (in a pipeline).