fix: fix teamwork cpu

sportorg · Jun 2, 2024 · 3b1a5b5 · 3b1a5b5
1 parent de16f00
commit 3b1a5b5
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/sportorg/modules/teamwork/client.py b/sportorg/modules/teamwork/client.py
@@ -17,7 +17,7 @@ def __init__(self, in_queue: queue.Queue):
     def __call__(self, conn: socket.socket) -> None:
         try:
             while True:
-                cmd = self._in_queue.get_nowait()
+                cmd = self._in_queue.get(timeout=0.1)
                 conn.sendall(cmd.get_packet())
         except queue.Empty:
             return

diff --git a/sportorg/modules/teamwork/server.py b/sportorg/modules/teamwork/server.py
@@ -80,7 +80,7 @@ def __init__(self, selector: selectors.BaseSelector, in_queue: Queue, logger):
     def __call__(self, socks: List[socket.socket]) -> None:
         try:
             while True:
-                command = self._in_queue.get_nowait()
+                command = self._in_queue.get(timeout=0.1)
                 for sock in socks:
                     if command.is_sender(sock):
                         continue