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

Class PauseableStartedTask

java.lang.Object

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

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

All Implemented Interfaces:

Task

@ThreadSafe
final class PauseableStartedTask
extends StartedTask

Wrapper of a single compute task that can be paused.

It is responsible for data consistency of the task.

Field Summary

Fields

Modifier and Type	Field and Description
private static org.slf4j.Logger	logger
private java.util.concurrent.atomic.AtomicBoolean	paused

Fields inherited from class pl.edu.agh.age.services.worker.internal.task.StartedTask

runnable

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
void	pause()
void	resume()

Methods inherited from class pl.edu.agh.age.services.worker.internal.task.StartedTask

cancel, className, cleanUp, future, isRunning, runnable, stop, 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

paused

private final java.util.concurrent.atomic.AtomicBoolean paused

Constructor Detail

PauseableStartedTask

PauseableStartedTask(java.lang.String className,
                     Pauseable runnable,
                     ListenableScheduledFuture<?> future)

Method Detail

pause

public void pause()

Specified by:

pause in interface Task

Overrides:

pause in class StartedTask

resume

public void resume()

Specified by:

resume in interface Task

Overrides:

resume in class StartedTask