Searched refs:TaskQueue (Results 1 – 3 of 3) sorted by relevance
34 class TaskQueue {42 explicit Task(Callable C, TaskQueue &Parent) in Task()64 TaskQueue *Parent;69 TaskQueue(ThreadPool &Scheduler) : Scheduler(Scheduler) { (void)Scheduler; } in TaskQueue() function72 ~TaskQueue() { in ~TaskQueue()
296 std::deque<std::shared_future<SmallString<0>>> TaskQueue; in runDeltaPass() local310 TaskQueue.clear(); in runDeltaPass()320 TaskQueue.emplace_back(ChunkThreadPool.async( in runDeltaPass()336 while (!TaskQueue.empty()) { in runDeltaPass()337 auto &Future = TaskQueue.front(); in runDeltaPass()342 TaskQueue.pop_front(); in runDeltaPass()344 unsigned NumScheduledTasks = NumChunksProcessed + TaskQueue.size(); in runDeltaPass()347 TaskQueue.emplace_back(ChunkThreadPool.async( in runDeltaPass()
26 TaskQueue TQ(TP); in TEST_F()70 TaskQueue TQ(TP); in TEST_F()100 TaskQueue TQ(TP); in TEST_F()