Lines Matching refs:results_queue
52 self.results_queue = Queue.Queue()
58 def worker(drone, results_queue):
62 in results_queue.
65 @param results_queue: A queue, into which the worker places
69 results_queue.put(ThreadedTaskQueue.result(
117 while not self.results_queue.empty():
118 drone_results = self.results_queue.get()
133 drone_utility. The results_queue and drone_threads will be cleared.
143 if not self.results_queue.empty():
146 'through get_results.' % self.results_queue)
156 args=(drone, self.results_queue))
