Searched refs:worker_queue (Results 1 – 1 of 1) sorted by relevance
76 worker_queue = queue.Queue() variable83 global worker_queue85 worker_queue.put(event)94 def worker_flush(worker_queue): argument100 worker_queue_int = worker_queue_int + worker_queue.get(True, 1)103 while (worker_queue_int or not worker_queue.empty()):106 if not worker_queue.empty():107 worker_queue_int = worker_queue_int + worker_queue.get()113 if worker_thread_exit and worker_queue.empty() and not worker_queue_int:116 worker_thread = Thread(target=worker_flush, args=(worker_queue,))