Package modelarium.multithreading.requestresponse

Class CoordinatorRequestHandler.AllWorkersUpdateCoordinator

java.lang.Object

modelarium.multithreading.requestresponse.CoordinatorRequestHandler

modelarium.multithreading.requestresponse.CoordinatorRequestHandler.AllWorkersUpdateCoordinator

Enclosing class:

CoordinatorRequestHandler

public static class CoordinatorRequestHandler.AllWorkersUpdateCoordinator
extends CoordinatorRequestHandler

Handles synchronisation for when all workers have updated the coordinator.

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
AllWorkersUpdateCoordinator(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

AllWorkersUpdateCoordinator

public AllWorkersUpdateCoordinator(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