def run(self):
while True:
try:
commandToken = self.inputCommandQueue.get_nowait() # Get orders
if commandToken.shutdown:
self._logInfo("Shutting down")
self.closing = True
self.pool.shutdown()
self.pool.join()
return # Exit the tread.
else:
self._logError("Unknown command token")
pass # Unknown command, ignore.
except Queue.Empty:
#self._log("Nothing in queue")
time.sleep(0.5)
评论列表
文章目录