Lines Matching refs:Queue
26 CV.wait(Lock, [&] { return ShouldStop || !Queue.empty(); }); in work()
28 Queue.clear(); in work()
33 std::pop_heap(Queue.begin(), Queue.end()); in work()
34 Task = std::move(Queue.back()); in work()
35 Queue.pop_back(); in work()
49 if (Stat.Active == 1 && Queue.empty()) { in work()
93 Queue.push_back(std::move(T)); in push()
94 std::push_heap(Queue.begin(), Queue.end()); in push()
107 Queue.push_back(std::move(T)); in append()
110 std::make_heap(Queue.begin(), Queue.end()); in append()
125 for (Task &T : Queue) in boost()
131 std::make_heap(Queue.begin(), Queue.end()); in boost()
139 [&] { return Queue.empty() && Stat.Active == 0; }); in blockUntilIdleForTest()