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

Updated wrong names.

comparison

equal deleted inserted replaced

-:70ca1d99f3fd
+:551d9fc0a2ba
+# 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