Lines Matching defs:queues_
120 queues_.emplace_back(std::make_unique<QueueImpl>(0));
138 if (V8_LIKELY(static_cast<int>(queues_.size()) >= required_queues)) {
139 return queues_[task_id].get();
145 int num_queues = static_cast<int>(queues_.size());
148 queues_.emplace_back(std::make_unique<QueueImpl>(steal_from));
163 for (auto& queue : queues_) {
170 return queues_[task_id].get();
201 queue_to_add, next_task_id(queue_to_add, queues_.size()),
205 queue = queues_[queue_to_add].get();
239 queue_to_add, next_task_id(queue_to_add, queues_.size()),
245 auto* queue = queues_[queue_to_add].get();
373 for (size_t steal_trials = 0; steal_trials < queues_.size();
375 if (steal_task_id >= static_cast<int>(queues_.size())) {
430 for (size_t steal_trials = 0; steal_trials < queues_.size();
432 if (steal_task_id >= static_cast<int>(queues_.size())) {
450 auto* steal_queue = queues_[steal_from_task_id].get();
477 auto* steal_queue = queues_[steal_from_task_id].get();
503 // {queues_mutex_} protectes {queues_};
505 std::vector<std::unique_ptr<QueueImpl>> queues_;