Searched refs:ThreadedTaskQueue (Results 1 – 4 of 4) sorted by relevance
61 task_queue = thread_lib.ThreadedTaskQueue()105 task_queue = thread_lib.ThreadedTaskQueue()148 task_queue = thread_lib.ThreadedTaskQueue()152 thread_lib.ThreadedTaskQueue.result(drone1, self.mock_return))154 thread_lib.ThreadedTaskQueue.result(drone1, self.mock_return))164 thread_lib.ThreadedTaskQueue.result(drone1, self.mock_return))166 thread_lib.ThreadedTaskQueue.result(drone2, self.mock_return))181 task_queue = thread_lib.ThreadedTaskQueue()
76 class ThreadedTaskQueue(drone_task_queue.DroneTaskQueue): class102 results_queue.put(ThreadedTaskQueue.result(190 target=ThreadedTaskQueue.worker,
191 self._refresh_task_queue = thread_lib.ThreadedTaskQueue(561 thread_lib.ThreadedTaskQueue(
477 thread_lib.ThreadedTaskQueue.result(