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

Common: Accept a lock in LockingAgentEventQueueDecorator's constructor

This commit is contained in:
Mike Salvatore 2022-09-29 12:39:17 -04:00
parent 91375cdff2
commit 3344300f84
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/common/event_queue/locking_agent_event_queue_decorator.py
View File

@ -11,8 +11,8 @@ class LockingAgentEventQueueDecorator(IAgentEventQueue):
Makes an IAgentEventQueue thread-safe by locking publish() Makes an IAgentEventQueue thread-safe by locking publish()
""" """
def __init__(self, agent_event_queue: IAgentEventQueue): def __init__(self, agent_event_queue: IAgentEventQueue, lock: Lock):
self._lock = Lock() self._lock = lock
self._agent_event_queue = agent_event_queue self._agent_event_queue = agent_event_queue
def subscribe_all_events(self, subscriber: AgentEventSubscriber): def subscribe_all_events(self, subscriber: AgentEventSubscriber):