org.opt4j.common.completer

Class ParallelIndividualCompleter

java.lang.Object

org.opt4j.common.completer.SequentialIndividualCompleter

org.opt4j.common.completer.ParallelIndividualCompleter

All Implemented Interfaces:

IndividualCompleter, OptimizerStateListener

public class ParallelIndividualCompleter
extends SequentialIndividualCompleter
implements OptimizerStateListener

The ParallelIndividualCompleter completes Individuals with multiple threads.

Author:

lukasiewycz

Constructor Summary

Constructors

Constructor and Description
ParallelIndividualCompleter(Control control, Decoder decoder, Evaluator evaluator, int maxThreads) Constructs a ParallelIndividualCompleter with a specified maximal number of concurrent threads.

Method Summary

Modifier and Type	Method and Description
void	complete(Iterable<? extends Individual> iterable) Decodes and evaluates all Individuals in the Iterable if they are not already evaluated.
void	optimizationStarted(Optimizer optimizer) Invoked if the Optimizer starts the optimization process.
void	optimizationStopped(Optimizer optimizer) Invoked if the Optimizer stops the optimization process.

Methods inherited from class org.opt4j.common.completer.SequentialIndividualCompleter

complete

Methods inherited from class java.lang.Object

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

Constructor Detail

ParallelIndividualCompleter

@Inject
public ParallelIndividualCompleter(Control control,
                                           Decoder decoder,
                                           Evaluator evaluator,
                                           int maxThreads)

Constructs a ParallelIndividualCompleter with a specified maximal number of concurrent threads.

Parameters:

control - the control

decoder - the decoder

evaluator - the evaluator

maxThreads - the maximal number of parallel threads (using namespace ParallelIndividualCompleter)

Method Detail

complete

public void complete(Iterable<? extends Individual> iterable)
              throws TerminationException

Description copied from interface: IndividualCompleter

Decodes and evaluates all Individuals in the Iterable if they are not already evaluated.

Specified by:

complete in interface IndividualCompleter

Overrides:

complete in class SequentialIndividualCompleter

Parameters:

iterable - the set of individuals to be completed

Throws:

TerminationException - if the optimization is terminated

optimizationStarted

public void optimizationStarted(Optimizer optimizer)

Description copied from interface: OptimizerStateListener

Invoked if the Optimizer starts the optimization process.

Specified by:

optimizationStarted in interface OptimizerStateListener

Parameters:

optimizer - the optimizer

optimizationStopped

public void optimizationStopped(Optimizer optimizer)

Description copied from interface: OptimizerStateListener

Invoked if the Optimizer stops the optimization process.

Specified by:

optimizationStopped in interface OptimizerStateListener

Parameters:

optimizer - the optimizer