pl.edu.agh.age.services.worker.internal.task

Class StartedTask

java.lang.Object

pl.edu.agh.age.services.worker.internal.task.StartedTask

All Implemented Interfaces:

Task

Direct Known Subclasses:

PauseableStartedTask

@ThreadSafe
class StartedTask
extends java.lang.Object
implements Task

Wrapper of a single compute task.

It is responsible for data consistency of the task.

Field Summary

Fields

Modifier and Type	Field and Description
private java.lang.String	className
private ListenableScheduledFuture<?>	future
private java.util.concurrent.locks.ReadWriteLock	lock
private static org.slf4j.Logger	logger
protected java.lang.Runnable	runnable

Constructor Summary

Constructors

Constructor and Description
StartedTask(java.lang.String className, java.lang.Runnable runnable, ListenableScheduledFuture<?> future)

Method Summary

Modifier and Type	Method and Description
void	cancel()
java.lang.String	className()
void	cleanUp()
ListenableScheduledFuture<?>	future()
boolean	isRunning()
void	pause()
void	resume()
java.lang.Runnable	runnable()
void	stop()
java.lang.String	toString()

Methods inherited from class java.lang.Object

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

Field Detail

logger

private static final org.slf4j.Logger logger

lock

private final java.util.concurrent.locks.ReadWriteLock lock

className

private final java.lang.String className

runnable

protected final java.lang.Runnable runnable

future

private final ListenableScheduledFuture<?> future

Constructor Detail

StartedTask

StartedTask(java.lang.String className,
            java.lang.Runnable runnable,
            ListenableScheduledFuture<?> future)

Method Detail

isRunning

public final boolean isRunning()

Specified by:

isRunning in interface Task

className

public final java.lang.String className()

Specified by:

className in interface Task

future

public final ListenableScheduledFuture<?> future()

Specified by:

future in interface Task

Returns:

a future for the running task.

Throws:

java.lang.IllegalStateException - when task is not scheduled.

runnable

public final java.lang.Runnable runnable()

Specified by:

runnable in interface Task

Returns:

the running task.

Throws:

java.lang.IllegalStateException - when task is not scheduled.

pause

public void pause()

Specified by:

pause in interface Task

resume

public void resume()

Specified by:

resume in interface Task

stop

public void stop()

Specified by:

stop in interface Task

cleanUp

public void cleanUp()

Specified by:

cleanUp in interface Task

cancel

public void cancel()

Specified by:

cancel in interface Task

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object