Package org.anchoranalysis.experiment.bean.processor

Class SequentialProcessor<T extends InputFromManager,S>

Object

AnchorBean<JobProcessor<T,S>>

JobProcessor<T,S>

SequentialProcessor<T,S>

Type Parameters:

T - input-object type

S - shared-object type

All Implemented Interfaces:

ReplaceTask<T,S>

public class SequentialProcessor<T extends InputFromManager,S>
extends JobProcessor<T,S>

Executes jobs sequentially, without any parallelism.

This is the simplest form of a JobProcessor.

Author:

Owen Feehan

Constructor Summary

Constructors

Constructor	Description
SequentialProcessor()

Method Summary

Modifier and Type	Method	Description
protected TaskStatistics	execute(Outputter rootOutputter, List<T> inputs, ParametersExperiment parametersExperiment)	Executes the task on all inputs.

Methods inherited from class org.anchoranalysis.experiment.bean.processor.JobProcessor

executeLogStatistics, getTask, hasVeryQuickPerInputExecution, isInputCompatibleWith, isSuppressExceptions, replaceTask, setSuppressExceptions, setTask

Methods inherited from class org.anchoranalysis.bean.AnchorBean

checkMisconfigured, describeBean, describeChildren, duplicateBean, fields, findFieldsOfClass, getBeanName, getLocalPath, localise, toString

Methods inherited from class java.lang.Object

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

Constructor Details

SequentialProcessor

public SequentialProcessor()

Method Details

execute

protected TaskStatistics execute(Outputter rootOutputter,
 List<T> inputs,
 ParametersExperiment parametersExperiment)
                          throws ExperimentExecutionException

Description copied from class: JobProcessor

Executes the task on all 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).

Specified by:

execute in class JobProcessor<T extends InputFromManager,S>

Parameters:

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.

Returns:

statistics about the success/failure/execution-time etc. of applying the task to inputs.

Throws:

ExperimentExecutionException - if anything goes wrong executing the experiment (but not necessarily if a processing a particular input fails when suppressExceptions == true.