m.giller/matrix-clock
1
0
Fork 0
Code Issues 2 Pull requests Projects Releases 4 Packages Wiki Activity

Hmm

Browse source
This commit is contained in:
Maximilian Giller 2024-01-30 20:04:01 +01:00
parent 1094fce783
commit 44890aced6
1 changed files with 2 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
src/handler/action_queue.py
View file

@ -5,14 +5,14 @@ from typing import Optional
class ActionQueue: class ActionQueue:
def __init__(self) -> None: def __init__(self) -> None:
self.queued_actions: asyncio.Queue = asyncio.Queue() self.queued_actions: asyncio.Queue = asyncio.Queue()
self.idle_action: Optional[any] = None self.idle_action: tuple = (None,[],{})
self.queue_task = asyncio.create_task(self.run_queue()) self.queue_task = asyncio.create_task(self.run_queue())
self.idle_action_task = None self.idle_action_task = None
async def run_queue(self): async def run_queue(self):
# try: # try:
while True: while True:
if self.queued_actions.empty() and self.idle_action is not None: if self.queued_actions.empty() and self.idle_action[0] is not None:
self.idle_action_task = asyncio.create_task(self.idle_action[0](*(self.idle_action[1]), **(self.idle_action[2]))) self.idle_action_task = asyncio.create_task(self.idle_action[0](*(self.idle_action[1]), **(self.idle_action[2])))
action = await self.queued_actions.get() action = await self.queued_actions.get()