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

Interview prep for xAI

comparison

equal deleted inserted replaced

-:b9a40c633c93
+:68fa88ac73fe
+# 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