Put output in separate thread to fix threadsearch delay

gentoomen · Feb 4, 2016 · 253fa3d · 253fa3d
1 parent bc25286
commit 253fa3d
Show file tree

Hide file tree

Showing 2 changed files with 11 additions and 4 deletions.
diff --git a/api/irc.py b/api/irc.py
@@ -2,6 +2,7 @@
 import log
 import ssl
 import Queue
+import threading
 
 connection = None
 commandQueue = None
@@ -29,6 +30,7 @@ def disconnect():
     connection.shutdown(socket.SHUT_RDWR)
     connection.close()
     connection = None
+    commandQueue = None
 
 ## 
 def readEvent():
@@ -46,11 +48,16 @@ def readEvent():
             return None
         readbuffer += data
 
-def sendAllCommands():
+def consumeAndSendCommands():
     global commandQueue
     global connection
-    while not commandQueue.empty():
-        connection.sendall(commandQueue.get())
+    while True:
+        connection.sendall(commandQueue.get(block=True))
+
+def startOutputThread():
+    consumer = threading.Thread(target=consumeAndSendCommands)
+    consumer.setDaemon(True)
+    consumer.start()
 
 def sendCommand(command):
     global commandQueue

diff --git a/bhottu.py b/bhottu.py
@@ -69,8 +69,8 @@ def main():
     while True:
         if not makeConnection():
             break
+        startOutputThread()
         while True:
-            sendAllCommands()
             event = readEvent()
             if event == None:
                 break