Searched refs:pending_tasks_ (Results 1 – 6 of 6) sorted by relevance
23 pending_tasks_.push_back(TestPendingTask(from_here, std::move(task), in PostDelayedTask()33 pending_tasks_.push_back(TestPendingTask(from_here, std::move(task), in PostNonNestableDelayedTask()48 return std::move(pending_tasks_); in TakePendingTasks()53 return pending_tasks_.size(); in NumPendingTasks()58 return !pending_tasks_.empty(); in HasPendingTask()63 return pending_tasks_.front().GetTimeToRun() - base::TimeTicks(); in NextPendingTaskDelay()68 return pending_tasks_.back().GetTimeToRun() - base::TimeTicks(); in FinalPendingTaskDelay()73 pending_tasks_.clear(); in ClearPendingTasks()83 tasks_to_run.swap(pending_tasks_); in RunPendingTasks()
82 base::circular_deque<TestPendingTask> pending_tasks_; variable
51 if (max_concurrency > (active_workers_ + pending_tasks_)) { in NotifyConcurrencyIncrease()52 num_tasks_to_post = max_concurrency - active_workers_ - pending_tasks_; in NotifyConcurrencyIncrease()53 pending_tasks_ += num_tasks_to_post; in NotifyConcurrencyIncrease()138 --pending_tasks_; in CanRunFirstTask()163 if (max_concurrency > active_workers_ + pending_tasks_) { in DidRunTask()164 num_tasks_to_post = max_concurrency - active_workers_ - pending_tasks_; in DidRunTask()165 pending_tasks_ += num_tasks_to_post; in DidRunTask()
93 size_t pending_tasks_ = 0; variable
41 pending_tasks_(pending_tasks) {} in ItemParallelJob()91 task->SetupInternal(pending_tasks_, &items_, start_index); in Run()109 pending_tasks_->Wait(); in Run()
137 base::Semaphore* pending_tasks_; variable