Searched refs:pending_tasks_ (Results 1 – 8 of 8) sorted by relevance
22 pending_tasks_.push_back( in PostDelayedTask()33 pending_tasks_.push_back( in PostNonNestableDelayedTask()47 return pending_tasks_; in GetPendingTasks()52 return !pending_tasks_.empty(); in HasPendingTask()57 return pending_tasks_.front().GetTimeToRun() - base::TimeTicks(); in NextPendingTaskDelay()62 pending_tasks_.clear(); in ClearPendingTasks()69 tasks_to_run.swap(pending_tasks_); in RunPendingTasks()77 while (!pending_tasks_.empty()) { in RunUntilIdle()
76 std::deque<TestPendingTask> pending_tasks_; variable
130 while (!pending_tasks_.empty()) in ~PosixDynamicThreadPool()131 pending_tasks_.pop(); in ~PosixDynamicThreadPool()155 pending_tasks_.push(*pending_task); in AddTask()159 if (static_cast<size_t>(num_idle_threads_) >= pending_tasks_.size()) { in AddTask()175 if (pending_tasks_.empty()) { // No work available, wait for work. in WaitForTask()184 if (pending_tasks_.empty()) { in WaitForTask()191 PendingTask pending_task = pending_tasks_.front(); in WaitForTask()192 pending_tasks_.pop(); in WaitForTask()
471 PendingTaskSet pending_tasks_; member in base::SequencedWorkerPool::Inner663 pending_tasks_.insert(sequenced); in PostTask()725 if (pending_tasks_.empty() && waiting_thread_count_ == threads_.size()) in CleanupForTesting()1017 PendingTaskSet::iterator i = pending_tasks_.begin(); in GetWork()1021 while (i != pending_tasks_.end()) { in GetWork()1045 pending_tasks_.erase(i++); in GetWork()1056 pending_tasks_.erase(i); in GetWork()1063 pending_tasks_.erase(i); in GetWork()1163 for (PendingTaskSet::const_iterator i = pending_tasks_.begin(); in PrepareToStartAdditionalThreadIfHelpful()1164 i != pending_tasks_.end(); ++i) { in PrepareToStartAdditionalThreadIfHelpful()
87 TaskQueue pending_tasks_; variable
31 return pool_->pending_tasks_; in pending_tasks()
138 pending_tasks_.emplace_back( in SendRequest()142 if (pending_tasks_.size() == 1) // More means check is scheduled. in SendRequest()147 VLOG(4) << "CurlHttpClient::CheckTasks, size=" << pending_tasks_.size(); in CheckTasks()149 std::partition(pending_tasks_.begin(), pending_tasks_.end(), in CheckTasks()150 [](const decltype(pending_tasks_)::value_type& value) { in CheckTasks()155 for (auto it = ready_begin; it != pending_tasks_.end(); ++it) { in CheckTasks()165 pending_tasks_.erase(ready_begin, pending_tasks_.end()); in CheckTasks()167 if (pending_tasks_.empty()) { in CheckTasks()
41 pending_tasks_; variable