Package de.aristaflow.adept2.util.threading

Class PipelineFlushRunnable<P>

java.lang.Object

de.aristaflow.adept2.util.threading.PipelineFlushRunnable<P>

Type Parameters:

P - The type of objects that identify a pipeline.

All Implemented Interfaces:

Runnable

@Deprecated
public class PipelineFlushRunnable<P>
extends Object
implements Runnable

Deprecated.

Use ObjectSpecificFlushCallable instead.

A runnable that executes a specific task exclusively without any pipeline running concurrently. After the task has terminated, the pipelines will be restarted, unless another exclusive task is executed concurrently.

Author:

Ulrich Kreher

Field Summary

Fields

Modifier and Type	Field	Description
protected boolean	abortedPending	Deprecated. Whether the flush has aborted pending work.
protected Collection<PipelineRunnable<P>>	await	Deprecated. All pipelines of which the termination needs to be awaited.
protected AbstractPipeliningExecutor<?,P>	executor	Deprecated. The executor for restarting the pipelines.
protected Logger	logger	Deprecated. The logger which to use for runtime exceptions stemming from executing the task or interrupts sent when awaiting the termination of the pipelines.
protected Runnable	task	Deprecated. The task to run without any pipeline running.

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	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.

Method Summary

Modifier and Type	Method	Description
void	run()	Deprecated.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

task

protected final Runnable task

Deprecated.

The task to run without any pipeline running.

await

protected final Collection<PipelineRunnable<P>> await

Deprecated.

All pipelines of which the termination needs to be awaited.

abortedPending

protected final boolean abortedPending

Deprecated.

Whether the flush has aborted pending work.

executor

protected final AbstractPipeliningExecutor<?,P> executor

Deprecated.

The executor for restarting the pipelines.

logger

protected final Logger logger

Deprecated.

The logger which to use for runtime exceptions stemming from executing the task or interrupts sent when awaiting the termination of the pipelines.

Constructor Detail

PipelineFlushRunnable

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

Parameters:

task - The task to run exclusively.

await - All pipelines for which to await their termination.

abortedPending - Whether the flush has aborted pending work.

executor - The pipeline executor to restart the pipelines after the exclusive task.

logger - The logger which to use for runtime exceptions stemming from executing the task or interrupts sent when awaiting the termination of the pipelines.

Method Detail

run

public void run()

Deprecated.

Specified by:

run in interface Runnable