blob: 21be5c7d867bcc8419e1f2c9c841ccd11614566c (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
|
package simulator.engine;
import core.*;
import prefs.VSPrefs;
import simulator.VSLogging;
import events.internal.VSMessageReceiveEvent;
import java.util.*;
import java.util.concurrent.CopyOnWriteArrayList;
/**
* Abstract base implementation of SimulationEngine that provides common
* functionality for both headless and visual simulation engines.
*/
public abstract class AbstractSimulationEngine implements SimulationEngine {
protected final VSPrefs prefs;
protected final List<VSInternalProcess> processes;
protected final List<SimulationVisualizer> visualizers;
protected final VSTaskManager taskManager;
protected VSLogging loging;
protected long time;
protected boolean isPaused;
protected boolean isResetted;
protected boolean hasFinished;
public AbstractSimulationEngine(VSPrefs prefs, VSLogging loging) {
this.prefs = prefs;
this.loging = loging;
this.processes = new ArrayList<>();
this.visualizers = new CopyOnWriteArrayList<>();
this.taskManager = new VSTaskManager(prefs, null); // We'll inject visualization later
this.time = 0;
this.isPaused = true;
this.isResetted = true;
this.hasFinished = false;
}
@Override
public void sendMessage(VSMessage message) {
// Schedule message delivery to all processes (broadcast model)
scheduleMessageDelivery(message, time);
// Notify visualizers
for (SimulationVisualizer visualizer : visualizers) {
visualizer.onMessageSent(message);
}
// Log the message
if (loging != null) {
loging.log("Message sent; ID: " + message.getMessageID() +
"; Protocol: " + message.getName());
}
}
protected abstract long calculateDeliveryTime(VSMessage message);
protected abstract void scheduleMessageDelivery(VSMessage message, long deliveryTime);
@Override
public void addProcess(VSInternalProcess process) {
processes.add(process);
// Notify visualizers
for (SimulationVisualizer visualizer : visualizers) {
visualizer.onProcessAdded(process);
}
}
@Override
public void removeProcess(VSInternalProcess process) {
processes.remove(process);
// Notify visualizers
for (SimulationVisualizer visualizer : visualizers) {
visualizer.onProcessRemoved(process);
}
}
@Override
public List<VSInternalProcess> getProcesses() {
return new ArrayList<>(processes);
}
@Override
public VSInternalProcess getProcess(int index) {
if (index >= 0 && index < processes.size()) {
return processes.get(index);
}
return null;
}
@Override
public int getNumProcesses() {
return processes.size();
}
@Override
public VSTaskManager getTaskManager() {
return taskManager;
}
@Override
public long getTime() {
return time;
}
@Override
public void setTime(long time) {
this.time = time;
// Notify visualizers
for (SimulationVisualizer visualizer : visualizers) {
visualizer.onTimeChanged(time);
}
}
@Override
public void reset() {
// Reset state
isResetted = true;
isPaused = true;
hasFinished = false;
time = 0;
// Reset all processes
for (VSInternalProcess process : processes) {
process.reset();
}
// Reset task manager
taskManager.reset();
// Notify visualizers
for (SimulationVisualizer visualizer : visualizers) {
visualizer.onSimulationReset();
}
}
@Override
public void play() {
isPaused = false;
isResetted = false;
// Notify visualizers
for (SimulationVisualizer visualizer : visualizers) {
visualizer.onSimulationStarted();
}
}
@Override
public void pause() {
isPaused = true;
// Notify visualizers
for (SimulationVisualizer visualizer : visualizers) {
visualizer.onSimulationPaused();
}
}
@Override
public boolean isPaused() {
return isPaused;
}
@Override
public boolean isResetted() {
return isResetted;
}
@Override
public boolean hasFinished() {
return hasFinished;
}
@Override
public void setFinished(boolean finished) {
this.hasFinished = finished;
if (finished) {
// Notify visualizers
for (SimulationVisualizer visualizer : visualizers) {
visualizer.onSimulationFinished();
}
}
}
@Override
public void addVisualizer(SimulationVisualizer visualizer) {
visualizers.add(visualizer);
}
@Override
public void removeVisualizer(SimulationVisualizer visualizer) {
visualizers.remove(visualizer);
}
/**
* Set the logging instance.
*/
public void setLogging(VSLogging loging) {
this.loging = loging;
}
}
|
