/home/mrjunejune/zenbu: grok_interview/thread.py comparison

Merged

comparison

equal deleted inserted replaced

-:983769fba767
+:d64a8c189a77
+# 1. data struture {}
+#    - multiple threads can access it
+#    - multiple threads can edit it if it is editable. (mutex)
+from hashlib import sha256
+from threading import Lock
+class Subscribers:
+def __init__(self):
+self.id = sha256()
+def on_event(self, event):
+pass
+class Publisher:
+def __init__(self):
+self._subscritions = {}
+self.lock = Lock()
+def publish_event(self, event):
+for subscriber_id, subscriber in enumerate(self._subscritions):
+subscriber.on_event(event)
+def add_subscribers(self, subscriber: Subscribers):
+with self.lock:
+self._subscritions[subscriber.id] = subscriber
+def remove_subscribers(self, subscriber: Subscribers):
+with self.lock:
+del self._subscritions[subscriber.id]

Mercurial