Lukas/carrotcoin
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Fix a race condition

Browse Source
This commit is contained in:
Lukas Fürderer
2026-01-05 12:02:27 +01:00
parent a3b92fcc72
commit de62f95f45
1 changed files with 4 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
observer.py
View File

@@ -11,9 +11,10 @@ class Observer:
self.__receivers_list[identifier].add(queue) self.__receivers_list[identifier].add(queue)
return Subscription(self, identifier, queue) return Subscription(self, identifier, queue)
def publish(self, identifier, message): def publish(self, identifier, message):
if identifier in self.__receivers_list: with self.__lock:
for queue in self.__receivers_list[identifier]: if identifier in self.__receivers_list:
queue.put(message) for queue in self.__receivers_list[identifier]:
queue.put(message)
def quit(self, identifer, queue): def quit(self, identifer, queue):
with self.__lock: with self.__lock:
self.__receivers_list[identifer].remove(queue) self.__receivers_list[identifer].remove(queue)