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()
46 class ThreadedTaskQueue(drone_task_queue.DroneTaskQueue): class69 results_queue.put(ThreadedTaskQueue.result(155 target=ThreadedTaskQueue.worker,
192 self._refresh_task_queue = thread_lib.ThreadedTaskQueue(547 thread_lib.ThreadedTaskQueue(
477 thread_lib.ThreadedTaskQueue.result(