Searched refs:results_queue (Results 1 – 4 of 4) sorted by relevance
52 self.results_queue = Queue.Queue()58 def worker(drone, results_queue): argument69 results_queue.put(ThreadedTaskQueue.result(117 while not self.results_queue.empty():118 drone_results = self.results_queue.get()143 if not self.results_queue.empty():146 'through get_results.' % self.results_queue)156 args=(drone, self.results_queue))
70 task_queue.worker(drone, task_queue.results_queue)71 result = task_queue.results_queue.get()73 self.assertTrue(task_queue.results_queue.empty() and151 task_queue.results_queue.put(153 task_queue.results_queue.put(162 self.assertTrue(task_queue.results_queue.empty())163 task_queue.results_queue.put(165 task_queue.results_queue.put(182 task_queue.results_queue.put(1)185 task_queue.results_queue.get()
476 self.manager._refresh_task_queue.results_queue.put(
48 self.results_queue = [] # Accessors must synchronize themselves.55 self.results_queue.append(test)66 current = self.results_queue67 self.results_queue = []