pl.edu.agh.age.compute.stream

Class StreamAgents

java.lang.Object

pl.edu.agh.age.compute.stream.StreamAgents

All Implemented Interfaces:

java.lang.Runnable, Manager

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

Main runtime for stream-like agents processing.

Field Summary

Fields

Modifier and Type	Field and Description
private DistributionUtilities	distributionUtilities
private java.util.List<Workplace<Agent>>	localWorkplaces
private static org.slf4j.Logger	logger
private LoggingService	loggingService
private UnicastMessenger	messenger
private IMap<java.lang.Long,io.vavr.collection.Map<java.lang.Object,java.lang.Object>>	statistics
private StopCondition	stopCondition
private ThreadPool	threadPool
private TopologyProvider<java.lang.Long>	topologyProvider
private IdGenerator	workplaceIdGenerator
private IMap<java.lang.Long,WorkerAddress>	workplacesLocations

Constructor Summary

Constructors

Constructor and Description
StreamAgents(Configuration configuration, ThreadPool threadPool, DistributionUtilities distributionUtilities, UnicastMessenger messenger, TopologyProvider<?> topologyProvider)

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>>	getLocalStatistics() Returns a read-only view of local statistics map of a current node.
io.vavr.collection.Map<java.lang.Long,io.vavr.collection.Set<java.lang.String>>	getNeighboursOf(long workplaceId) Returns a read-only view of global statistics map filtered only for neighbours of the given workplace.
io.vavr.collection.Map<java.lang.Long,io.vavr.collection.Map<java.lang.Object,java.lang.Object>>	getNeighboursStatistics(long workplaceId) Returns a read-only view of global statistics map filtered only for neighbours of the given workplace.
io.vavr.collection.Map<java.lang.Long,io.vavr.collection.Map<java.lang.Object,java.lang.Object>>	getStatistics() Returns a read-only view of global statistics map of all available nodes.
int	getTotalWorkplacesCount() Returns the number of all workplaces that participate in computations.
boolean	isStopConditionReached()
void	migrate(Agent agent, long sourceWorkplace, long targetWorkplace) Migrates an agent to a workplace with the given ID in neighbourhood.
void	migrate(Agent agent, long sourceWorkplace, java.lang.String neighbourAnnotation) Migrates an agent to a workplace with the given annotation in neighbourhood.
void	migrateUnconditionally(Agent agent, long sourceWorkplace, long targetWorkplace) Migrates an agent to a workplace with the given ID.
private void	performMigration(Agent agent, long targetWorkplace) Performs actual migration without any verification of arguments
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()
java.lang.String	toString()
private static void	waitFor(StopCondition stopCondition)

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

messenger

private final UnicastMessenger messenger

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 java.util.List<Workplace<Agent>> localWorkplaces

stopCondition

private final StopCondition stopCondition

loggingService

private final LoggingService loggingService

topologyProvider

private final TopologyProvider<java.lang.Long> topologyProvider

Constructor Detail

StreamAgents

@Inject
public StreamAgents(Configuration configuration,
                            ThreadPool threadPool,
                            DistributionUtilities distributionUtilities,
                            UnicastMessenger messenger,
                            TopologyProvider<?> topologyProvider)

Method Detail

run

public void run()

Specified by:

run in interface java.lang.Runnable

cancelWorkplaceFuture

private static void cancelWorkplaceFuture(ListenableFuture<?> f)

waitFor

private static void waitFor(StopCondition stopCondition)
                     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

getTotalWorkplacesCount

public int getTotalWorkplacesCount()

Description copied from interface: Manager

Returns the number of all workplaces that participate in computations.

Specified by:

getTotalWorkplacesCount in interface Manager

getStatistics

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

Description copied from interface: Manager

Returns a read-only view of global statistics map of all available nodes.

Specified by:

getStatistics in interface Manager

getLocalStatistics

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

Description copied from interface: Manager

Returns a read-only view of local statistics map of a current node.

Specified by:

getLocalStatistics in interface Manager

getNeighboursStatistics

public io.vavr.collection.Map<java.lang.Long,io.vavr.collection.Map<java.lang.Object,java.lang.Object>> getNeighboursStatistics(long workplaceId)

Description copied from interface: Manager

Returns a read-only view of global statistics map filtered only for neighbours of the given workplace.

Specified by:

getNeighboursStatistics in interface Manager

getNeighboursOf

public io.vavr.collection.Map<java.lang.Long,io.vavr.collection.Set<java.lang.String>> getNeighboursOf(long workplaceId)

Description copied from interface: Manager

Returns a read-only view of global statistics map filtered only for neighbours of the given workplace.

Specified by:

getNeighboursOf in interface Manager

migrate

public void migrate(Agent agent,
                    long sourceWorkplace,
                    long targetWorkplace)

Description copied from interface: Manager

Migrates an agent to a workplace with the given ID in neighbourhood.

This method always use the current topology.

Specified by:

migrate in interface Manager

migrate

public void migrate(Agent agent,
                    long sourceWorkplace,
                    java.lang.String neighbourAnnotation)

Description copied from interface: Manager

Migrates an agent to a workplace with the given annotation in neighbourhood.

This method always use the current topology.

Specified by:

migrate in interface Manager

migrateUnconditionally

public void migrateUnconditionally(Agent agent,
                                   long sourceWorkplace,
                                   long targetWorkplace)

Description copied from interface: Manager

Migrates an agent to a workplace with the given ID.

This method makes it possible to bypass a current topology.

Specified by:

migrateUnconditionally 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

performMigration

private void performMigration(Agent agent,
                              long targetWorkplace)

Performs actual migration without any verification of arguments