Package modelarium.multithreading.requestresponse

Class CoordinatorRequestHandler.AllWorkersFinishTick

java.lang.Object

modelarium.multithreading.requestresponse.CoordinatorRequestHandler

modelarium.multithreading.requestresponse.CoordinatorRequestHandler.AllWorkersFinishTick

Enclosing class:

CoordinatorRequestHandler

public static class CoordinatorRequestHandler.AllWorkersFinishTick
extends CoordinatorRequestHandler

Handles synchronisation for when all workers finish a tick.

Nested Class Summary

Nested classes/interfaces inherited from class modelarium.multithreading.requestresponse.CoordinatorRequestHandler

CoordinatorRequestHandler.AgentAccess, CoordinatorRequestHandler.AllWorkersFinishTick, CoordinatorRequestHandler.AllWorkersUpdateCoordinator, CoordinatorRequestHandler.EnvironmentAttributesAccess, CoordinatorRequestHandler.FilteredAgentsAccess, CoordinatorRequestHandler.UpdateCoordinatorAgents

Constructor Summary

Constructors

Constructor	Description
AllWorkersFinishTick(String threadName, ModelSettings settings, BlockingQueue<Response> responseQueue, AgentSet globalAgentSet, Environment environment)

Method Summary

Modifier and Type	Method	Description
void	handleRequest(Request request)	Handles an incoming request from a worker.

Methods inherited from class modelarium.multithreading.requestresponse.CoordinatorRequestHandler

getEnvironment, getGlobalAgentSet, getResponseQueue, getSettings, getThreadName, getWorkersWaiting, handleCoordinatorRequest, initialise, setWorkersWaiting

Methods inherited from class java.lang.Object

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

Constructor Details

AllWorkersFinishTick

public AllWorkersFinishTick(String threadName,
 ModelSettings settings,
 BlockingQueue<Response> responseQueue,
 AgentSet globalAgentSet,
 Environment environment)

Method Details

handleRequest

public void handleRequest(Request request)
                   throws InterruptedException

Description copied from class: CoordinatorRequestHandler

Handles an incoming request from a worker. Must be implemented by subclasses.

Specified by:

handleRequest in class CoordinatorRequestHandler

Parameters:

request - the request to handle

Throws:

InterruptedException