Searched refs:results_queue (Results 1 – 5 of 5) sorted by relevance
82 self.results_queue = Queue.Queue()91 def worker(drone, results_queue): argument102 results_queue.put(ThreadedTaskQueue.result(151 while not self.results_queue.empty():152 drone_results = self.results_queue.get()177 if not self.results_queue.empty():180 'through get_results.' % self.results_queue)191 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(
35 def _start_upload_threads(self, results_queue, upload_id, argument37 self.results_queue = results_queue47 def _start_download_threads(self, results_queue, worker_queue): argument48 self.results_queue = results_queue
48 self.results_queue = [] # Accessors must synchronize themselves.55 self.results_queue.append(test)66 current = self.results_queue67 self.results_queue = []