Lines Matching refs:WorkQueue
67 class WorkQueue : public PlatformThread::Delegate { class
69 explicit WorkQueue(int thread_count);
70 ~WorkQueue() override;
257 WorkQueue queue(kThreadCount); // Start the threads. in TEST_F()
401 WorkQueue queue(kThreadCount); // Start the threads. in TEST_F()
494 WorkQueue::WorkQueue(int thread_count) in WorkQueue() function in base::__anon414633000111::WorkQueue
521 WorkQueue::~WorkQueue() { in ~WorkQueue()
534 int WorkQueue::GetThreadId() { in GetThreadId()
540 bool WorkQueue::EveryIdWasAllocated() const { in EveryIdWasAllocated()
545 TimeDelta WorkQueue::GetAnAssignment(int thread_id) { in GetAnAssignment()
555 void WorkQueue::WorkIsCompleted(int thread_id) { in WorkIsCompleted()
560 int WorkQueue::task_count() const { in task_count()
565 bool WorkQueue::allow_help_requests() const { in allow_help_requests()
570 bool WorkQueue::shutdown() const { in shutdown()
579 bool WorkQueue::ThreadSafeCheckShutdown(int thread_count) { in ThreadSafeCheckShutdown()
590 void WorkQueue::thread_shutting_down() { in thread_shutting_down()
596 Lock* WorkQueue::lock() { in lock()
600 ConditionVariable* WorkQueue::work_is_available() { in work_is_available()
604 ConditionVariable* WorkQueue::all_threads_have_ids() { in all_threads_have_ids()
608 ConditionVariable* WorkQueue::no_more_tasks() { in no_more_tasks()
612 void WorkQueue::ResetHistory() { in ResetHistory()
619 int WorkQueue::GetMinCompletionsByWorkerThread() const { in GetMinCompletionsByWorkerThread()
626 int WorkQueue::GetMaxCompletionsByWorkerThread() const { in GetMaxCompletionsByWorkerThread()
633 int WorkQueue::GetNumThreadsTakingAssignments() const { in GetNumThreadsTakingAssignments()
641 int WorkQueue::GetNumThreadsCompletingTasks() const { in GetNumThreadsCompletingTasks()
649 int WorkQueue::GetNumberOfCompletedTasks() const { in GetNumberOfCompletedTasks()
656 void WorkQueue::SetWorkTime(TimeDelta delay) { in SetWorkTime()
660 void WorkQueue::SetTaskCount(int count) { in SetTaskCount()
664 void WorkQueue::SetAllowHelp(bool allow) { in SetAllowHelp()
668 void WorkQueue::SetShutdown() { in SetShutdown()
673 void WorkQueue::SpinUntilAllThreadsAreWaiting() { in SpinUntilAllThreadsAreWaiting()
684 void WorkQueue::SpinUntilTaskCountLessThan(int task_count) { in SpinUntilTaskCountLessThan()
714 void WorkQueue::ThreadMain() { in ThreadMain()