Package modelarium.multithreading

Class WorkerThread<T extends Results>

java.lang.Object

modelarium.multithreading.WorkerThread<T>

Type Parameters:

T - the type of Results this worker will return

All Implemented Interfaces:

Callable<Results>

public class WorkerThread<T extends Results>
extends Object
implements Callable<Results>

Represents a single worker thread responsible for simulating one subset of agents across the configured number of ticks.

Each WorkerThread operates on its own AgentSet, may use a local WorkerCache for caching, and optionally communicates with a coordinator via RequestResponseInterface if synchronisation is enabled.

Constructor Summary

Constructors

Constructor	Description
WorkerThread(String threadName, ModelSettings settings, RequestResponseController requestResponseController, AgentSet agents)	Constructs a new worker thread to simulate a subset of agents.

Method Summary

Modifier and Type	Method	Description
Results	call()	Executes the simulation loop for this worker.

Methods inherited from class java.lang.Object

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

Constructor Details

WorkerThread

public WorkerThread(String threadName,
 ModelSettings settings,
 RequestResponseController requestResponseController,
 AgentSet agents)

Constructs a new worker thread to simulate a subset of agents.

Parameters:

threadName - the thread's name (typically its numeric ID as a string)

settings - the simulation settings

requestResponseController - the controller for cross-thread coordination

agents - the agents assigned to this thread

Method Details

call

public Results call()
             throws InterruptedException,
NoSuchMethodException,
InvocationTargetException,
InstantiationException,
IllegalAccessException

Executes the simulation loop for this worker.

This includes calling the scheduler each tick, synchronising with the coordinator if needed, and collecting agent results after the simulation ends.

Specified by:

call in interface Callable<T extends Results>

Returns:

a Results object containing final agent-level outputs

Throws:

InterruptedException

NoSuchMethodException

InvocationTargetException

InstantiationException

IllegalAccessException