Package es.urjc.etsii.grafo.executors

Class Executor<S extends Solution<S,I>,I extends Instance>

java.lang.Object

es.urjc.etsii.grafo.executors.Executor<S,I>

Type Parameters:

S - Solution class

I - Instance class

Direct Known Subclasses:

ConcurrentExecutor, SequentialExecutor

public abstract class Executor<S extends Solution<S,I>,I extends Instance>
extends Object

Processes work units

Field Summary

Fields

Modifier and Type	Field	Description
static final int	EXTRA_SECS_BEFORE_WARNING
protected final InstanceManager<I>	instanceManager
protected final IOManager<S,I>	io
protected final ReferenceResultManager	referenceResultManager
protected final SolverConfig	solverConfig
protected final Optional<TimeLimitCalculator<S,I>>	timeLimitCalculator
static final int	UNDEF_TIME

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	Executor(Optional<SolutionValidator<S,I>> validator, Optional<TimeLimitCalculator<S,I>> timeLimitCalculator, IOManager<S,I> io, InstanceManager<I> instanceManager, SolverConfig solverConfig, List<ExceptionHandler<S,I>> exceptionHandlers, ReferenceResultManager referenceResultManager)	Fill common values used by all executors

Method Summary

Modifier and Type	Method	Description
protected WorkUnitResult<S,I>	doWork(WorkUnit<S,I> workUnit)	Execute a single iteration for the given (experiment, instance, algorithm, iterationId)
static <S extends Solution<S, I>, I extends Instance> void	endTimeControl(Optional<TimeLimitCalculator<S,I>> timeLimitCalculator, WorkUnit<S,I> workUnit)	If time control is enabled, remove it and check ellapsed time to see if too many time has been spent
abstract void	executeExperiment(Experiment<S,I> experiment, List<String> instanceNames, long startTimestamp)
protected void	exportAlgorithmInstanceSolution(WorkUnitResult<S,I> r)
protected void	exportInstanceSolution(WorkUnitResult<S,I> r)
me.tongfei.progressbar.ProgressBar	getGlobalSolvingProgressBar(String expName, Map<String,Map<Algorithm<S,I>,List<WorkUnit<S,I>>>> workUnits)
protected Map<String,Map<Algorithm<S,I>,List<WorkUnit<S,I>>>>	getOrderedWorkUnits(Experiment<S,I> experiment, List<String> instancePaths, int repetitions)	Create workunits with solve order
static me.tongfei.progressbar.ProgressBarBuilder	getPBarBuilder(String taskname)
protected boolean	improves(WorkUnitResult<S,I> candidate, WorkUnitResult<S,I> best)
String	instanceName(String instancePath)
protected void	processWorkUnitResult(WorkUnitResult<S,I> r, me.tongfei.progressbar.ProgressBar pb)
abstract void	shutdown()	Finalize and destroy all resources, we have finished and are shutting down now.
abstract void	startup()	Allocate resources and prepare for execution

Methods inherited from class java.lang.Object

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

Field Details

EXTRA_SECS_BEFORE_WARNING

public static final int EXTRA_SECS_BEFORE_WARNING

See Also:

• Constant Field Values

UNDEF_TIME

public static final int UNDEF_TIME

See Also:

• Constant Field Values

timeLimitCalculator

protected final Optional<TimeLimitCalculator<S extends Solution<S,I>,I extends Instance>> timeLimitCalculator

io

protected final IOManager<S extends Solution<S,I>,I extends Instance> io

instanceManager

protected final InstanceManager<I extends Instance> instanceManager

referenceResultManager

protected final ReferenceResultManager referenceResultManager

solverConfig

protected final SolverConfig solverConfig

Constructor Details

Executor

protected Executor(Optional<SolutionValidator<S,I>> validator,
 Optional<TimeLimitCalculator<S,I>> timeLimitCalculator,
 IOManager<S,I> io,
 InstanceManager<I> instanceManager,
 SolverConfig solverConfig,
 List<ExceptionHandler<S,I>> exceptionHandlers,
 ReferenceResultManager referenceResultManager)

Fill common values used by all executors

Parameters:

validator - solution validator if available

timeLimitCalculator - time limit calculator if exists

io - IO manager

exceptionHandlers - list of exception handlers available

referenceResultManager - reference result manager

Method Details

endTimeControl

public static <S extends Solution<S,
I>,
I extends Instance>
void endTimeControl(Optional<TimeLimitCalculator<S,I>> timeLimitCalculator,
 WorkUnit<S,I> workUnit)

If time control is enabled, remove it and check ellapsed time to see if too many time has been spent

Type Parameters:

S - Solution class

I - Instance class

Parameters:

timeLimitCalculator - time limit calculator if implemented

workUnit - current work unit

executeExperiment

public abstract void executeExperiment(Experiment<S,I> experiment,
 List<String> instanceNames,
 long startTimestamp)

startup

public abstract void startup()

Allocate resources and prepare for execution

shutdown

public abstract void shutdown()

Finalize and destroy all resources, we have finished and are shutting down now.

doWork

protected WorkUnitResult<S,I> doWork(WorkUnit<S,I> workUnit)

Execute a single iteration for the given (experiment, instance, algorithm, iterationId)

Parameters:

workUnit - Minimum unit of work, cannot be divided further.

processWorkUnitResult

protected void processWorkUnitResult(WorkUnitResult<S,I> r,
 me.tongfei.progressbar.ProgressBar pb)

exportAlgorithmInstanceSolution

protected void exportAlgorithmInstanceSolution(WorkUnitResult<S,I> r)

exportInstanceSolution

protected void exportInstanceSolution(WorkUnitResult<S,I> r)

getOrderedWorkUnits

protected Map<String,Map<Algorithm<S,I>,List<WorkUnit<S,I>>>> getOrderedWorkUnits(Experiment<S,I> experiment,
 List<String> instancePaths,
 int repetitions)

Create workunits with solve order

Parameters:

experiment - experiment definition

instancePaths - instance name list

repetitions - how many times should we repeat the (instance, algorithm) pair

Returns:

Map of workunits per instance

improves

protected boolean improves(WorkUnitResult<S,I> candidate,
 WorkUnitResult<S,I> best)

instanceName

public String instanceName(String instancePath)

getPBarBuilder

public static me.tongfei.progressbar.ProgressBarBuilder getPBarBuilder(String taskname)

getGlobalSolvingProgressBar

public me.tongfei.progressbar.ProgressBar getGlobalSolvingProgressBar(String expName,
 Map<String,Map<Algorithm<S,I>,List<WorkUnit<S,I>>>> workUnits)