event simulation

Author: gvwilson

requirements.txt

@@ -3,6 +3,7 @@ greenlet
 kaleido
 pandas
 plotly
+prettytable
 py-des-lib
 pydot
 pyfakefs

src/eventsim/Makefile

@@ -1,4 +1,7 @@
 TARGETS=\
-  wait_and_work.out
+  multiprocess.out \
+  wait_and_work.out \
+  wait_event.out \
+  wait_work_record.out
 
 include ../../examples.mk

src/eventsim/index.md

@@ -10,3 +10,7 @@ syllabus:
 
 -   Basic ideas of discrete event simulation
 -   `wait_and_work.py`: work a fixed time, wait a fixed time
+-   `wait_work_record.py`: record events and display table of results
+-   `multiprocess.py`: two independent processes
+-   `wait_event.py`: one waits for the other to finish
+    -   But events happen once

src/eventsim/multiprocess.out

@@ -0,0 +1,10 @@
+| time | component | message    |
+|----: | :---------| :----------|
+|    0 | Worker.0  | start work |
+|    0 | Worker.1  | start work |
+|    2 | Worker.0  | start work |
+|    2 | Worker.1  | start work |
+|    4 | Worker.0  | start work |
+|    4 | Worker.1  | start work |
+|    6 | Worker.0  | finished   |
+|    6 | Worker.1  | finished   |

src/eventsim/multiprocess.py

@@ -0,0 +1,28 @@
+from pydes import Component, Simulator
+from util import format_log
+
+
+class Worker(Component):
+    NUM_STEPS = 3
+    WORK_TIME = 2
+
+    def __init__(self, sim):
+        self._sim = sim
+
+    def main(self):
+        for i in range(self.NUM_STEPS):
+            self._sim.record(self, "start work")
+            self._sim.sleep(self.WORK_TIME)
+        self._sim.record(self, "finished")
+
+
+def simulate():
+    sim = Simulator(trace=False)
+    sim.schedule(Worker(sim))
+    sim.schedule(Worker(sim))
+    sim.run()
+    print(format_log(sim.records()))
+
+
+if __name__ == "__main__":
+    simulate()

src/eventsim/util.py

@@ -0,0 +1,18 @@
+from prettytable import MARKDOWN, PrettyTable
+
+
+FIELDS = {
+    "time": "r",
+    "component": "l",
+    "message": "l",
+}
+
+
+def format_log(records):
+    table = PrettyTable(field_names=FIELDS.keys())
+    table.set_style(MARKDOWN)
+    for field, align in FIELDS.items():
+        table.align[field] = align
+    for rec in records:
+        table.add_row([rec.time, str(rec.component), rec.value])
+    return table

src/eventsim/wait_and_work.out

@@ -1,4 +1,4 @@
 start to work at 0
-start to work at 5
-start to work at 10
-finished working at 15
+start to work at 2
+start to work at 4
+finished working at 6

src/eventsim/wait_and_work.py

@@ -3,7 +3,7 @@
 
 class Worker(Component):
     NUM_STEPS = 3
-    WORK_TIME = 5
+    WORK_TIME = 2
 
     def __init__(self, sim):
         self._sim = sim

src/eventsim/wait_event.out

@@ -0,0 +1,11 @@
+| time | component | message    |
+|----: | :---------| :----------|
+|    0 | Worker.0  | start work |
+|    0 | Worker.1  | start work |
+|    2 | Worker.1  | start work |
+|    4 | Worker.1  | start work |
+|    6 | Worker.1  | finished   |
+|    6 | Worker.0  | start work |
+|    8 | Worker.0  | start work |
+|   10 | Worker.0  | start work |
+|   12 | Worker.0  | finished   |

src/eventsim/wait_event.py

@@ -0,0 +1,36 @@
+from pydes import Component, Event, Simulator
+from util import format_log
+
+
+class Worker(Component):
+    NUM_STEPS = 3
+    WORK_TIME = 2
+
+    def __init__(self, sim, event, wait_at_start):
+        self._sim = sim
+        self._event = event
+        self._wait_at_start = wait_at_start
+
+    def main(self):
+        if self._wait_at_start:
+            self._sim.record(self, "start work")
+            self._event.wait()
+        for i in range(self.NUM_STEPS):
+            self._sim.record(self, "start work")
+            self._sim.sleep(self.WORK_TIME)
+        self._sim.record(self, "finished")
+        if not self._wait_at_start:
+            self._event.set()
+
+
+def simulate():
+    sim = Simulator(trace=False)
+    event = Event(sim)
+    sim.schedule(Worker(sim, event, True))
+    sim.schedule(Worker(sim, event, False))
+    sim.run()
+    print(format_log(sim.records()))
+
+
+if __name__ == "__main__":
+    simulate()

src/eventsim/wait_work_record.out

@@ -0,0 +1,6 @@
+| time | component | message    |
+|----: | :---------| :----------|
+|    0 | Worker.0  | start work |
+|    2 | Worker.0  | start work |
+|    4 | Worker.0  | start work |
+|    6 | Worker.0  | finished   |

src/eventsim/wait_work_record.py

@@ -0,0 +1,28 @@
+from pydes import Component, Simulator
+from util import format_log
+
+
+class Worker(Component):
+    NUM_STEPS = 3
+    WORK_TIME = 2
+
+    def __init__(self, sim):
+        self._sim = sim
+
+    def main(self):
+        for i in range(self.NUM_STEPS):
+            self._sim.record(self, "start work")
+            self._sim.sleep(self.WORK_TIME)
+        self._sim.record(self, "finished")
+
+
+def simulate():
+    sim = Simulator(trace=False)
+    worker = Worker(sim)
+    sim.schedule(worker)
+    sim.run()
+    print(format_log(sim.records()))
+
+
+if __name__ == "__main__":
+    simulate()