pl.edu.agh.age.compute.stream

Class Workplace<T extends Agent>

java.lang.Object

pl.edu.agh.age.compute.stream.Workplace<T>

All Implemented Interfaces:

java.lang.Runnable

public class Workplace<T extends Agent>
extends java.lang.Object
implements java.lang.Runnable

Field Summary

Fields

Modifier and Type	Field and Description
private AfterStepAction<T,?>	afterStepAction
private BeforeStepAction<T>	beforeStepAction
private Environment	environment
private long	id Must be a non-negative long.
private java.util.concurrent.atomic.AtomicReference<io.vavr.collection.List<T>>	incomingAgents
private io.vavr.collection.List<T>	initialPopulation
private static org.slf4j.Logger	logger
private Manager	manager
private java.util.concurrent.atomic.AtomicLong	step
private Step<T>	stepOperations

Constructor Summary

Constructors

Constructor and Description
Workplace(long id, java.lang.Iterable<T> initialPopulation, BeforeStepAction<T> beforeStepAction, Step<T> stepOperations, AfterStepAction<T,?> afterStepAction, Manager manager)
Workplace(long id, io.vavr.collection.List<T> initialPopulation, BeforeStepAction<T> beforeStepAction, Step<T> stepOperations, AfterStepAction<T,?> afterStepAction, Manager manager)

Method Summary

Modifier and Type	Method and Description
void	addAgentInNextStep(T agent)
long	id()
void	run()
java.lang.String	toString()

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

id

private final long id

Must be a non-negative long.

initialPopulation

private final io.vavr.collection.List<T extends Agent> initialPopulation

step

private final java.util.concurrent.atomic.AtomicLong step

beforeStepAction

private final BeforeStepAction<T extends Agent> beforeStepAction

stepOperations

private final Step<T extends Agent> stepOperations

afterStepAction

private final AfterStepAction<T extends Agent,?> afterStepAction

manager

private final Manager manager

environment

private final Environment environment

incomingAgents

private final java.util.concurrent.atomic.AtomicReference<io.vavr.collection.List<T extends Agent>> incomingAgents

Constructor Detail

Workplace

public Workplace(long id,
                 java.lang.Iterable<T> initialPopulation,
                 BeforeStepAction<T> beforeStepAction,
                 Step<T> stepOperations,
                 AfterStepAction<T,?> afterStepAction,
                 Manager manager)

Workplace

public Workplace(long id,
                 io.vavr.collection.List<T> initialPopulation,
                 BeforeStepAction<T> beforeStepAction,
                 Step<T> stepOperations,
                 AfterStepAction<T,?> afterStepAction,
                 Manager manager)

Method Detail

id

public final long id()

addAgentInNextStep

public final void addAgentInNextStep(T agent)

run

public void run()

Specified by:

run in interface java.lang.Runnable

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object