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

Class ComputationContext

java.lang.Object

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

public final class ComputationContext
extends java.lang.Object

Field Summary

Fields

Modifier and Type	Field and Description
private boolean	cleaned
private java.util.Set<CommunicationFacility>	communicationFacilities
private DistributionUtilities	computeDistributionUtilities
private DefaultThreadPool	computeThreadPool
private WorkerConfiguration	configuration
private @MonotonicNonNull Task	currentTask
private java.util.concurrent.locks.ReadWriteLock	lock
private static org.slf4j.Logger	logger
private @MonotonicNonNull org.springframework.context.support.AbstractApplicationContext	springContext

Constructor Summary

Constructors

Constructor and Description
ComputationContext(WorkerConfiguration configuration, java.util.Set<CommunicationFacility> communicationFacilities, DistributionUtilities computeDistributionUtilities)

Method Summary

Modifier and Type	Method and Description
void	cancel()
private void	checkIfTaskIsActive()
void	cleanUp()
private TaskBuilder	createTaskBuilder()
java.lang.String	currentTaskDescription()
boolean	isTaskActive()
void	pause()
void	resume()
void	startTask(ListeningScheduledExecutorService executorService, FutureCallback<java.lang.Object> callback)
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

configuration

private final WorkerConfiguration configuration

communicationFacilities

private final java.util.Set<CommunicationFacility> communicationFacilities

computeDistributionUtilities

private final DistributionUtilities computeDistributionUtilities

computeThreadPool

private final DefaultThreadPool computeThreadPool

lock

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

springContext

private @MonotonicNonNull org.springframework.context.support.AbstractApplicationContext springContext

currentTask

private @MonotonicNonNull Task currentTask

cleaned

private boolean cleaned

Constructor Detail

ComputationContext

public ComputationContext(WorkerConfiguration configuration,
                          java.util.Set<CommunicationFacility> communicationFacilities,
                          DistributionUtilities computeDistributionUtilities)

Method Detail

currentTaskDescription

public java.lang.String currentTaskDescription()

isTaskActive

public boolean isTaskActive()

startTask

public void startTask(ListeningScheduledExecutorService executorService,
                      FutureCallback<java.lang.Object> callback)
               throws FailedComputationSetupException

Throws:

FailedComputationSetupException

pause

public void pause()

resume

public void resume()

stop

public void stop()

cleanUp

public void cleanUp()

cancel

public void cancel()

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

checkIfTaskIsActive

@EnsuresNonNull(value="currentTask")
private void checkIfTaskIsActive()

createTaskBuilder

private TaskBuilder createTaskBuilder()
                               throws FailedComputationSetupException

Throws:

FailedComputationSetupException