public class Task
extends java.lang.Object
Modifier and Type | Class and Description |
---|---|
static class |
Task.WaitState |
Modifier and Type | Field and Description |
---|---|
private static Task |
_instance |
java.util.concurrent.atomic.AtomicBoolean |
abortAllFlag |
AnalysisData |
expression |
java.util.concurrent.ConcurrentLinkedDeque<java.lang.String> |
failedResults |
java.util.concurrent.ConcurrentLinkedDeque<java.lang.String> |
failedScripts |
java.util.concurrent.ConcurrentLinkedDeque<java.lang.String> |
finishedScripts |
java.util.Set<java.lang.String> |
modulesToExec |
java.util.concurrent.ConcurrentLinkedDeque<java.lang.String> |
noDiffExpFound |
java.util.concurrent.atomic.AtomicBoolean |
packagesFinishedFlag |
AnalysisParameters |
params |
java.util.concurrent.atomic.AtomicInteger |
processingStatus |
java.util.Set<java.lang.String> |
queryModules |
private int |
remainingAnalysisScripts |
java.util.concurrent.ConcurrentLinkedDeque<java.lang.String> |
runningScripts |
java.util.concurrent.ConcurrentHashMap<java.lang.String,ScriptExec> |
scriptExecs |
java.util.concurrent.ConcurrentHashMap<java.lang.String,Output> |
scriptOutputs |
protected java.lang.Thread |
scriptsStatusWatcher |
java.util.Map<java.lang.String,AnalysisParameters> |
specificParams |
java.lang.Runnable |
statusWatcher |
java.util.concurrent.ConcurrentLinkedDeque<java.lang.String> |
successfulScripts |
java.util.Set<java.lang.String> |
validQueryModules |
java.util.concurrent.ConcurrentHashMap<java.lang.String,Task.WaitState> |
waitState |
java.lang.Runnable |
zombieFinder |
Constructor and Description |
---|
Task(java.util.Set<java.lang.String> scriptsToExec,
AnalysisParameters params,
java.util.Map<java.lang.String,AnalysisParameters> specificParams,
AnalysisData expression) |
Modifier and Type | Method and Description |
---|---|
void |
abortAll() |
void |
addFinished(java.lang.String name,
boolean prefailed) |
private void |
checkForSuccess(java.lang.String name) |
private void |
defineStatusWatcher() |
private void |
defineZombieFinder() |
private boolean |
evaluateScriptForExecution(java.lang.String name) |
private boolean |
evaluateScriptInput(java.lang.String name) |
static Task |
getRunningTask() |
boolean |
isFailed() |
boolean |
isNotStarted() |
boolean |
isProcessing() |
boolean |
isSomeFailed() |
boolean |
isSuccess() |
private void |
playReady() |
private void |
preFailed(java.lang.String name) |
private void |
queueScriptForExecution(java.lang.String name) |
void |
start() |
private void |
updateStates() |
private void |
updateStatus()
Synchronized method to update the atomic status of the task.
|
public java.util.Set<java.lang.String> queryModules
public java.util.Set<java.lang.String> validQueryModules
public java.util.Set<java.lang.String> modulesToExec
public AnalysisParameters params
public java.util.Map<java.lang.String,AnalysisParameters> specificParams
public AnalysisData expression
public java.util.concurrent.atomic.AtomicBoolean packagesFinishedFlag
public java.util.concurrent.atomic.AtomicBoolean abortAllFlag
public java.util.concurrent.atomic.AtomicInteger processingStatus
public java.lang.Runnable statusWatcher
public java.lang.Runnable zombieFinder
public java.util.concurrent.ConcurrentLinkedDeque<java.lang.String> successfulScripts
public java.util.concurrent.ConcurrentLinkedDeque<java.lang.String> noDiffExpFound
public java.util.concurrent.ConcurrentLinkedDeque<java.lang.String> failedResults
public java.util.concurrent.ConcurrentLinkedDeque<java.lang.String> failedScripts
public java.util.concurrent.ConcurrentLinkedDeque<java.lang.String> runningScripts
public java.util.concurrent.ConcurrentLinkedDeque<java.lang.String> finishedScripts
public java.util.concurrent.ConcurrentHashMap<java.lang.String,ScriptExec> scriptExecs
public java.util.concurrent.ConcurrentHashMap<java.lang.String,Task.WaitState> waitState
public java.util.concurrent.ConcurrentHashMap<java.lang.String,Output> scriptOutputs
private int remainingAnalysisScripts
protected java.lang.Thread scriptsStatusWatcher
private static Task _instance
public Task(java.util.Set<java.lang.String> scriptsToExec, AnalysisParameters params, java.util.Map<java.lang.String,AnalysisParameters> specificParams, AnalysisData expression)
public void start()
private boolean evaluateScriptInput(java.lang.String name)
private boolean evaluateScriptForExecution(java.lang.String name)
private void queueScriptForExecution(java.lang.String name)
public boolean isNotStarted()
public boolean isProcessing()
public boolean isFailed()
public boolean isSomeFailed()
public boolean isSuccess()
private void defineStatusWatcher()
private void defineZombieFinder()
private void updateStatus()
public void addFinished(java.lang.String name, boolean prefailed)
private void checkForSuccess(java.lang.String name)
private void playReady()
private void preFailed(java.lang.String name)
private void updateStates()
public void abortAll()
public static Task getRunningTask()