p59342861
/
monkey
forked from p15670423/monkey
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Common: Accept a lock in LockingIslandEventQueueDecorator's constructor

This commit is contained in:
Mike Salvatore 2022-09-29 12:39:57 -04:00
parent 3344300f84
commit 00d72390ff
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
monkey/monkey_island/cc/event_queue/locking_island_event_queue_decorator.py
View File

@ -8,8 +8,8 @@ class LockingIslandEventQueueDecorator(IIslandEventQueue):
Makes an IIslandEventQueue thread-safe by locking publish() Makes an IIslandEventQueue thread-safe by locking publish()
""" """
def __init__(self, island_event_queue: IIslandEventQueue): def __init__(self, island_event_queue: IIslandEventQueue, lock: Lock):
self._lock = Lock() self._lock = lock
self._island_event_queue = island_event_queue self._island_event_queue = island_event_queue
def subscribe(self, topic: IslandEventTopic, subscriber: IslandEventSubscriber): def subscribe(self, topic: IslandEventTopic, subscriber: IslandEventSubscriber):