Package it.tidalwave.image.processor
Class LocalImagingTaskProcessor
- java.lang.Object
-
- it.tidalwave.image.processor.ImagingTaskProcessor
-
- it.tidalwave.image.processor.LocalImagingTaskProcessor
-
public class LocalImagingTaskProcessor extends ImagingTaskProcessor
- Author:
- Fabrizio Giudici
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description protected class
LocalImagingTaskProcessor.PoolThread
-
Field Summary
-
Fields inherited from class it.tidalwave.image.processor.ImagingTaskProcessor
freeWorkers, lock, maxWorkers
-
-
Constructor Summary
Constructors Constructor Description LocalImagingTaskProcessor()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description int
getWorkerCount()
java.util.Collection<java.io.Serializable>
getWorkerIds()
boolean
hasFileAccess()
Returns true if the tasks will be executed in a distributed context with the support of a distributed file system - that is, if each task is guaranteed to have a File access to the same set of data.boolean
isDistributed()
Returns true if the tasks will be executed in a distributed context (i.e.-
Methods inherited from class it.tidalwave.image.processor.ImagingTaskProcessor
addListener, cancellPendingTasks, changeFreeWorkerCount, getCompletedTaskCount, getInstance, getMaxWorkers, getNextTask, getPendingTaskCount, getRunningTaskCount, getStatistics, notifyTaskCompleted, popCompletedTask, post, post, postWithPriority, postWithPriority, processingResourcesAvailable, removeListener, setDefault, setMaxWorkers
-
-
-
-
Method Detail
-
isDistributed
public boolean isDistributed()
Returns true if the tasks will be executed in a distributed context (i.e. with different physical nodes - in single-node, multi-core contexts this method returns false.- Specified by:
isDistributed
in classImagingTaskProcessor
-
hasFileAccess
public boolean hasFileAccess()
Returns true if the tasks will be executed in a distributed context with the support of a distributed file system - that is, if each task is guaranteed to have a File access to the same set of data. Or if the context is a single-node, multi-core system, which of course has a single filesystem.- Specified by:
hasFileAccess
in classImagingTaskProcessor
-
getWorkerCount
public int getWorkerCount()
- Specified by:
getWorkerCount
in classImagingTaskProcessor
-
getWorkerIds
public java.util.Collection<java.io.Serializable> getWorkerIds()
- Specified by:
getWorkerIds
in classImagingTaskProcessor
-
-