T
- input-object typeS
- shared-object statepublic class DebugDependentProcessor<T extends InputFromManager,S> extends JobProcessor<T,S>
Constructor and Description |
---|
DebugDependentProcessor() |
Modifier and Type | Method and Description |
---|---|
protected TaskStatistics |
execute(Outputter rootOutputter,
List<T> inputs,
ParametersExperiment parametersExperiment)
Executes the task on all
inputs . |
int |
getKeepProcessorsFree()
How many processors to avoid using for the tasks.
|
int |
getMaxNumberProcessors()
An upper limit on the number of the processors that can be simultaneously used in parallel,
if they are available.
|
void |
setKeepProcessorsFree(int keepProcessorsFree)
How many processors to avoid using for the tasks.
|
void |
setMaxNumberProcessors(int maxNumberProcessors)
An upper limit on the number of the processors that can be simultaneously used in parallel,
if they are available.
|
executeLogStatistics, getTask, hasVeryQuickPerInputExecution, isInputCompatibleWith, isSuppressExceptions, replaceTask, setSuppressExceptions, setTask
checkMisconfigured, describeBean, describeChildren, duplicateBean, fields, findFieldsOfClass, getBeanName, getLocalPath, localise, toString
protected TaskStatistics execute(Outputter rootOutputter, List<T> inputs, ParametersExperiment parametersExperiment) throws ExperimentExecutionException
JobProcessor
inputs
.
It is expected that elements are removed from inputs
as they are consumed so as to
allow garbage-collection of these items before all jobs are processed (as the list might be
quite large).
execute
in class JobProcessor<T extends InputFromManager,S>
rootOutputter
- an outputter, bound to the base (root) output directory into which
outputted files are written.inputs
- the inputs to apply task
on.parametersExperiment
- parameters that exist pertaining to the experiment that is
underway.ExperimentExecutionException
- if anything goes wrong executing the experiment (but not
necessarily if a processing a particular input fails when suppressExceptions ==
true
.public int getMaxNumberProcessors()
If the current ParametersExperiment
suggests an alternative maximum, it is
afforded precedence over this property.
public void setMaxNumberProcessors(int maxNumberProcessors)
If the current ParametersExperiment
suggests an alternative maximum, it is
afforded precedence over this property.
public int getKeepProcessorsFree()
When using the maximum available number of processors, a certain amount are deliberately not used, to save them for other tasks on the operating system. This is particularly valuable on a desktop PC where other tasks (e.g web browsing) may be ongoing during processing.
public void setKeepProcessorsFree(int keepProcessorsFree)
When using the maximum available number of processors, a certain amount are deliberately not used, to save them for other tasks on the operating system. This is particularly valuable on a desktop PC where other tasks (e.g web browsing) may be ongoing during processing.
Copyright © 2010–2023 Owen Feehan, ETH Zurich, University of Zurich, Hoffmann-La Roche. All rights reserved.