org.hkijena.jipipe.ui.running

Class JIPipeRunnerQueue

java.lang.Object

org.hkijena.jipipe.ui.running.JIPipeRunnerQueue

public class JIPipeRunnerQueue
extends Object

Queue for JIPipeRunnable

Method Summary

Modifier and Type	Method and Description
void	cancel(JIPipeRunnable run) Cancels a runnable
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
void	onWorkerFinished(RunWorkerFinishedEvent event) Triggered when a worker is finished
void	onWorkerInterrupted(RunWorkerInterruptedEvent event) Triggered when a worker is interrupted
void	onWorkerProgress(RunWorkerProgressEvent event) Triggered when a worker reports progress
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

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()

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(RunWorkerFinishedEvent event)

Triggered when a worker is finished

Parameters:

event - Generated event

onWorkerInterrupted

public void onWorkerInterrupted(RunWorkerInterruptedEvent event)

Triggered when a worker is interrupted

Parameters:

event - Generated event

onWorkerProgress

public void onWorkerProgress(RunWorkerProgressEvent 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)