Package es.urjc.etsii.grafo.executors

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

java.lang.Object

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

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

Type Parameters:

S - Solution class

I - Instance class

@ConditionalOnExpression("${solver.parallelExecutor}")
public class ConcurrentExecutor<S extends Solution<S,I>,I extends Instance>
extends Executor<S,I>

Concurrent executor, execute multiple runs in parallel for a given instance-algorithm pair

Field Summary

Fields inherited from class es.urjc.etsii.grafo.executors.Executor

EXTRA_SECS_BEFORE_WARNING, instanceManager, io, referenceResultManager, solverConfig, timeLimitCalculator, UNDEF_TIME

Constructor Summary

Constructors

Constructor	Description
ConcurrentExecutor(SolverConfig solverConfig, Optional<SolutionValidator<S,I>> validator, Optional<TimeLimitCalculator<S,I>> timeLimitCalculator, IOManager<S,I> io, InstanceManager<I> instanceManager, List<ExceptionHandler<S,I>> exceptionHandlers, ReferenceResultManager referenceResultManager)	Create a new ConcurrentExecutor.

Method Summary

Modifier and Type	Method	Description
void	executeExperiment(Experiment<S,I> experiment, List<String> instanceNames, long startTimestamp)
void	shutdown()	Finalize and destroy all resources, we have finished and are shutting down now.
void	startup()	Allocate resources and prepare for execution

Methods inherited from class es.urjc.etsii.grafo.executors.Executor

doWork, endTimeControl, exportAlgorithmInstanceSolution, exportInstanceSolution, getGlobalSolvingProgressBar, getOrderedWorkUnits, getPBarBuilder, improves, instanceName, processWorkUnitResult

Methods inherited from class java.lang.Object

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

Constructor Details

ConcurrentExecutor

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

Create a new ConcurrentExecutor. Do not create executors manually, inject them.

Parameters:

solverConfig - Solver configuration instance

validator - Solution validator

io - IOManager

Method Details

executeExperiment

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

Specified by:

executeExperiment in class Executor<S extends Solution<S,I>,I extends Instance>

startup

public void startup()

Description copied from class: Executor

Allocate resources and prepare for execution

Specified by:

startup in class Executor<S extends Solution<S,I>,I extends Instance>

shutdown

public void shutdown()

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

Specified by:

shutdown in class Executor<S extends Solution<S,I>,I extends Instance>