pl.edu.agh.age.compute.ea

Class EvolutionaryAlgorithms

java.lang.Object

pl.edu.agh.age.compute.ea.EvolutionaryAlgorithms

All Implemented Interfaces:

java.lang.Runnable, Manager

public final class EvolutionaryAlgorithms
extends java.lang.Object
implements java.lang.Runnable, Manager

Main runtime for stream-like EA processing.

Field Summary

Fields

Modifier and Type	Field and Description
private DistributionUtilities	distributionUtilities
private io.vavr.collection.List<Workplace<Solution<?>>>	localWorkplaces
private static org.slf4j.Logger	logger
private IMap<java.lang.Long,io.vavr.collection.Map<java.lang.Object,java.lang.Object>>	statistics
private StopCondition	stopCondition
private ThreadPool	threadPool
private IdGenerator	workplaceIdGenerator
private IMap<java.lang.Long,WorkerAddress>	workplacesLocations

Constructor Summary

Constructors

Constructor and Description
EvolutionaryAlgorithms(Configuration<Solution<?>> configuration, ThreadPool threadPool, DistributionUtilities distributionUtilities)

Method Summary

Modifier and Type	Method and Description
private static void	cancelWorkplaceFuture(ListenableFuture<?> f)
io.vavr.collection.Map<java.lang.Long,io.vavr.collection.Map<java.lang.Object,java.lang.Object>>	globalStatistics() Returns a read-only view of global statistics map.
boolean	isStopConditionReached()
void	postStatistics(long id, io.vavr.collection.Map<java.lang.Object,java.lang.Object> workplaceStatistics) Posts provided statistics globally, mapping them to the workplace ID.
void	run()
<T> io.vavr.collection.Seq<T>	statisticsForKey(java.lang.Object key, java.lang.Class<T> valuesClass)
java.lang.String	toString()
private void	waitForStopCondition()

Methods inherited from class java.lang.Object

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

Field Detail

logger

private static final org.slf4j.Logger logger

threadPool

private final ThreadPool threadPool

distributionUtilities

private final DistributionUtilities distributionUtilities

workplaceIdGenerator

private final IdGenerator workplaceIdGenerator

statistics

private final IMap<java.lang.Long,io.vavr.collection.Map<java.lang.Object,java.lang.Object>> statistics

workplacesLocations

private final IMap<java.lang.Long,WorkerAddress> workplacesLocations

localWorkplaces

private final io.vavr.collection.List<Workplace<Solution<?>>> localWorkplaces

stopCondition

private final StopCondition stopCondition

Constructor Detail

EvolutionaryAlgorithms

@Inject
public EvolutionaryAlgorithms(Configuration<Solution<?>> configuration,
                                      ThreadPool threadPool,
                                      DistributionUtilities distributionUtilities)

Method Detail

run

public void run()

Specified by:

run in interface java.lang.Runnable

cancelWorkplaceFuture

private static void cancelWorkplaceFuture(ListenableFuture<?> f)

waitForStopCondition

private void waitForStopCondition()
                           throws java.lang.InterruptedException

Throws:

java.lang.InterruptedException

postStatistics

public void postStatistics(long id,
                           io.vavr.collection.Map<java.lang.Object,java.lang.Object> workplaceStatistics)

Description copied from interface: Manager

Posts provided statistics globally, mapping them to the workplace ID.

Specified by:

postStatistics in interface Manager

Parameters:

id - workplace id

workplaceStatistics - statistics as a map

globalStatistics

public io.vavr.collection.Map<java.lang.Long,io.vavr.collection.Map<java.lang.Object,java.lang.Object>> globalStatistics()

Description copied from interface: Manager

Returns a read-only view of global statistics map.

Specified by:

globalStatistics in interface Manager

statisticsForKey

public <T> io.vavr.collection.Seq<T> statisticsForKey(java.lang.Object key,
                                                      java.lang.Class<T> valuesClass)

Specified by:

statisticsForKey in interface Manager

isStopConditionReached

public boolean isStopConditionReached()

Specified by:

isStopConditionReached in interface Manager

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object