• Home
  • Raw
  • Download

Lines Matching refs:WorkQueue

69 class WorkQueue : public PlatformThread::Delegate {  class
71 explicit WorkQueue(int thread_count);
72 ~WorkQueue() override;
259 WorkQueue queue(kThreadCount); // Start the threads. in TEST_F()
409 WorkQueue queue(kThreadCount); // Start the threads. in TEST_F()
502 WorkQueue::WorkQueue(int thread_count) in WorkQueue() function in base::__anon16d4e8c80111::WorkQueue
529 WorkQueue::~WorkQueue() { in ~WorkQueue()
542 int WorkQueue::GetThreadId() { in GetThreadId()
548 bool WorkQueue::EveryIdWasAllocated() const { in EveryIdWasAllocated()
553 TimeDelta WorkQueue::GetAnAssignment(int thread_id) { in GetAnAssignment()
563 void WorkQueue::WorkIsCompleted(int thread_id) { in WorkIsCompleted()
568 int WorkQueue::task_count() const { in task_count()
573 bool WorkQueue::allow_help_requests() const { in allow_help_requests()
578 bool WorkQueue::shutdown() const { in shutdown()
587 bool WorkQueue::ThreadSafeCheckShutdown(int thread_count) { in ThreadSafeCheckShutdown()
598 void WorkQueue::thread_shutting_down() { in thread_shutting_down()
604 Lock* WorkQueue::lock() { in lock()
608 ConditionVariable* WorkQueue::work_is_available() { in work_is_available()
612 ConditionVariable* WorkQueue::all_threads_have_ids() { in all_threads_have_ids()
616 ConditionVariable* WorkQueue::no_more_tasks() { in no_more_tasks()
620 void WorkQueue::ResetHistory() { in ResetHistory()
627 int WorkQueue::GetMinCompletionsByWorkerThread() const { in GetMinCompletionsByWorkerThread()
634 int WorkQueue::GetMaxCompletionsByWorkerThread() const { in GetMaxCompletionsByWorkerThread()
641 int WorkQueue::GetNumThreadsTakingAssignments() const { in GetNumThreadsTakingAssignments()
649 int WorkQueue::GetNumThreadsCompletingTasks() const { in GetNumThreadsCompletingTasks()
657 int WorkQueue::GetNumberOfCompletedTasks() const { in GetNumberOfCompletedTasks()
664 void WorkQueue::SetWorkTime(TimeDelta delay) { in SetWorkTime()
668 void WorkQueue::SetTaskCount(int count) { in SetTaskCount()
672 void WorkQueue::SetAllowHelp(bool allow) { in SetAllowHelp()
676 void WorkQueue::SetShutdown() { in SetShutdown()
681 void WorkQueue::SpinUntilAllThreadsAreWaiting() { in SpinUntilAllThreadsAreWaiting()
692 void WorkQueue::SpinUntilTaskCountLessThan(int task_count) { in SpinUntilTaskCountLessThan()
722 void WorkQueue::ThreadMain() { in ThreadMain()