Package uk.ac.warwick.dcs.sherlock.engine.executor.work

Class WorkDetect

java.lang.Object

java.util.concurrent.ForkJoinTask<V>

java.util.concurrent.RecursiveTask<java.util.List<AbstractModelTaskRawResult>>

uk.ac.warwick.dcs.sherlock.engine.executor.work.WorkDetect

All Implemented Interfaces:

java.io.Serializable, java.util.concurrent.Future<java.util.List<AbstractModelTaskRawResult>>

public class WorkDetect
extends java.util.concurrent.RecursiveTask<java.util.List<AbstractModelTaskRawResult>>

Recursive task to run detectors

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor	Description
WorkDetect(JobStatus jobStatus, java.util.List<DetectorWorker> workers, int threshold)

Method Summary

Modifier and Type	Method	Description
protected java.util.List<AbstractModelTaskRawResult>	compute()
java.util.List<AbstractModelTaskRawResult>	getResults()

Methods inherited from class java.util.concurrent.RecursiveTask

exec, getRawResult, setRawResult

Methods inherited from class java.util.concurrent.ForkJoinTask

adapt, adapt, adapt, cancel, compareAndSetForkJoinTaskTag, complete, completeExceptionally, fork, get, get, getException, getForkJoinTaskTag, getPool, getQueuedTaskCount, getSurplusQueuedTaskCount, helpQuiesce, inForkJoinPool, invoke, invokeAll, invokeAll, invokeAll, isCancelled, isCompletedAbnormally, isCompletedNormally, isDone, join, peekNextLocalTask, pollNextLocalTask, pollSubmission, pollTask, quietlyComplete, quietlyInvoke, quietlyJoin, reinitialize, setForkJoinTaskTag, tryUnfork

Methods inherited from class java.lang.Object

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

Constructor Detail

WorkDetect

public WorkDetect(JobStatus jobStatus,
                  java.util.List<DetectorWorker> workers,
                  int threshold)

Method Detail

getResults

public java.util.List<AbstractModelTaskRawResult> getResults()

compute

protected java.util.List<AbstractModelTaskRawResult> compute()

Specified by:

compute in class java.util.concurrent.RecursiveTask<java.util.List<AbstractModelTaskRawResult>>