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 Executor

eventPublisher, EXTRA_SECS_BEFORE_WARNING, instanceManager, io, referenceResultManager, resultsSerializer, resultStore, 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, MorkEventPublisher eventPublisher, ResultStore<S,I> resultStore, ResultsSerializerListener<S,I> resultsSerializer)

Create a new ConcurrentExecutor.

Method Summary

Modifier and Type	Method	Description
void	executeExperiment(Experiment<S,I> experiment, List<String> instancePaths, 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 Executor

doWork, doWork, endTimeControl, exportAlgorithmInstanceSolution, exportInstanceSolution, finishInstance, getGlobalSolvingProgressBar, getOrderedWorkUnits, getPBarBuilder, improves, instanceName, processWorkUnitResult, serializePerInstance, warmup

Methods inherited from class 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,
 MorkEventPublisher eventPublisher,
 ResultStore<S,I> resultStore,
 ResultsSerializerListener<S,I> resultsSerializer)

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> instancePaths,
 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>