org.hkijena.jipipe.ui.running

Class JIPipeRunnerQueue

java.lang.Object

org.hkijena.jipipe.ui.running.JIPipeRunnerQueue

public class JIPipeRunnerQueue
extends Object

Queue for JIPipeRunnable

Constructor Summary

Constructors

Constructor and Description
JIPipeRunnerQueue(String name)

Method Summary

Modifier and Type	Method and Description
void	cancel(JIPipeRunnable run) Cancels a runnable
void	cancelAll()
void	cancelIf(Predicate<JIPipeRunnable> predicate)
void	clearQueue() Removes all enqueued (but not running tasks)
JIPipeRunWorker	enqueue(JIPipeRunnable run) Schedules a new runnable
JIPipeRunWorker	findWorkerOf(JIPipeRunnable run) Finds the worker associated to the JIPipeRunnable
JIPipeRunnable	getCurrentRun()
JIPipeRunWorker	getCurrentRunWorker()
EventBus	getEventBus()
static JIPipeRunnerQueue	getInstance()
Queue<JIPipeRunWorker>	getQueue()
boolean	isEmpty()
boolean	isRunningOrEnqueued(JIPipeRunnable runnable) Determines if a runnable is enqueued or running
boolean	isSilent()
void	onWorkerFinished(JIPipeRunnable.FinishedEvent event) Triggered when a worker is finished
void	onWorkerInterrupted(JIPipeRunnable.InterruptedEvent event) Triggered when a worker is interrupted
void	onWorkerProgress(JIPipeRunnable.ProgressEvent event) Triggered when a worker reports progress
void	setSilent(boolean silent)
int	size() The size of the queue (includes the currently running JIPipeProjectRun
void	tryDequeue() Attempts to run a scheduled run

Methods inherited from class java.lang.Object

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

Constructor Detail

JIPipeRunnerQueue

public JIPipeRunnerQueue(String name)

Method Detail

getInstance

public static JIPipeRunnerQueue getInstance()

Returns:

Singleton instance

isRunningOrEnqueued

public boolean isRunningOrEnqueued(JIPipeRunnable runnable)

Determines if a runnable is enqueued or running

Parameters:

runnable - the runnable

Returns:

if a runnable is enqueued or running

getQueue

public Queue<JIPipeRunWorker> getQueue()

isSilent

public boolean isSilent()

setSilent

public void setSilent(boolean silent)

isEmpty

public boolean isEmpty()

Returns:

true if nothing is running and the queue is empty

size

public int size()

The size of the queue (includes the currently running JIPipeProjectRun

Returns:

the size

enqueue

public JIPipeRunWorker enqueue(JIPipeRunnable run)

Schedules a new runnable

Parameters:

run - The runnable

Returns:

The worker associated to the run

findWorkerOf

public JIPipeRunWorker findWorkerOf(JIPipeRunnable run)

Finds the worker associated to the JIPipeRunnable

Parameters:

run - The runnable

Returns:

The associated worker

tryDequeue

public void tryDequeue()

Attempts to run a scheduled run

cancel

public void cancel(JIPipeRunnable run)

Cancels a runnable

Parameters:

run - The runnable

onWorkerFinished

public void onWorkerFinished(JIPipeRunnable.FinishedEvent event)

Triggered when a worker is finished

Parameters:

event - Generated event

onWorkerInterrupted

public void onWorkerInterrupted(JIPipeRunnable.InterruptedEvent event)

Triggered when a worker is interrupted

Parameters:

event - Generated event

onWorkerProgress

public void onWorkerProgress(JIPipeRunnable.ProgressEvent event)

Triggered when a worker reports progress

Parameters:

event - Generated event

getEventBus

public EventBus getEventBus()

Returns:

The event bus

getCurrentRunWorker

public JIPipeRunWorker getCurrentRunWorker()

Returns:

The current run

getCurrentRun

public JIPipeRunnable getCurrentRun()

Returns:

The current run

clearQueue

public void clearQueue()

Removes all enqueued (but not running tasks)

cancelAll

public void cancelAll()

cancelIf

public void cancelIf(Predicate<JIPipeRunnable> predicate)