Lines Matching refs:task_queue

61         task_queue = thread_lib.ThreadedTaskQueue()
70         task_queue.worker(drone, task_queue.results_queue)
71         result = task_queue.results_queue.get()
73         self.assertTrue(task_queue.results_queue.empty() and
105         task_queue = thread_lib.ThreadedTaskQueue()
114         task_queue.drone_threads[drone1] = waiting_worker
115         task_queue.drone_threads[drone2] = failing_worker
117                 target=task_queue.wait_on_drones)
131         self.assertTrue(task_queue.drone_threads == {})
135         task_queue.drone_threads[drone1] = quick_worker
139         task_queue.wait_on_drones()
140         self.assertTrue(task_queue.drone_threads == {})
148         task_queue = thread_lib.ThreadedTaskQueue()
151         task_queue.results_queue.put(
153         task_queue.results_queue.put(
155         self.god.stub_function(task_queue, 'wait_on_drones')
156         task_queue.wait_on_drones.expect_call()
158                           task_queue.get_results)
162         self.assertTrue(task_queue.results_queue.empty())
163         task_queue.results_queue.put(
165         task_queue.results_queue.put(
167         task_queue.wait_on_drones.expect_call()
168         results = task_queue.get_results()
181         task_queue = thread_lib.ThreadedTaskQueue()
182         task_queue.results_queue.put(1)
184                           task_queue.execute, [])
185         task_queue.results_queue.get()
186         task_queue.drone_threads[drone1] = None
188                           task_queue.execute, [])
189         task_queue.drone_threads = {}
206         task_queue.execute(drones, wait=False)
207         self.assertTrue(set(task_queue.drone_threads.keys()) == set(drones))
208         for drone, thread in task_queue.drone_threads.iteritems():
212         results = task_queue.get_results()
224         self.assertTrue(task_queue.execute(drones, wait=True)[drone1] ==