• Home
  • Raw
  • Download

Lines Matching refs:WorkQueue

63 class WorkQueue : public PlatformThread::Delegate {  class
65 explicit WorkQueue(int thread_count);
66 ~WorkQueue();
190 WorkQueue queue(kThreadCount); // Start the threads. in TEST_F()
390 WorkQueue queue(kThreadCount); // Start the threads. in TEST_F()
492 WorkQueue::WorkQueue(int thread_count) in WorkQueue() function in __anonca0a39970111::WorkQueue
518 WorkQueue::~WorkQueue() { in ~WorkQueue()
530 int WorkQueue::GetThreadId() { in GetThreadId()
536 bool WorkQueue::EveryIdWasAllocated() const { in EveryIdWasAllocated()
541 TimeDelta WorkQueue::GetAnAssignment(int thread_id) { in GetAnAssignment()
551 void WorkQueue::WorkIsCompleted(int thread_id) { in WorkIsCompleted()
556 int WorkQueue::task_count() const { in task_count()
561 bool WorkQueue::allow_help_requests() const { in allow_help_requests()
566 bool WorkQueue::shutdown() const { in shutdown()
575 bool WorkQueue::ThreadSafeCheckShutdown(int thread_count) { in ThreadSafeCheckShutdown()
586 void WorkQueue::thread_shutting_down() { in thread_shutting_down()
592 Lock* WorkQueue::lock() { in lock()
596 ConditionVariable* WorkQueue::work_is_available() { in work_is_available()
600 ConditionVariable* WorkQueue::all_threads_have_ids() { in all_threads_have_ids()
604 ConditionVariable* WorkQueue::no_more_tasks() { in no_more_tasks()
608 void WorkQueue::ResetHistory() { in ResetHistory()
615 int WorkQueue::GetMinCompletionsByWorkerThread() const { in GetMinCompletionsByWorkerThread()
622 int WorkQueue::GetMaxCompletionsByWorkerThread() const { in GetMaxCompletionsByWorkerThread()
629 int WorkQueue::GetNumThreadsTakingAssignments() const { in GetNumThreadsTakingAssignments()
637 int WorkQueue::GetNumThreadsCompletingTasks() const { in GetNumThreadsCompletingTasks()
645 int WorkQueue::GetNumberOfCompletedTasks() const { in GetNumberOfCompletedTasks()
652 TimeDelta WorkQueue::GetWorkTime() const { in GetWorkTime()
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()
691 void WorkQueue::ThreadMain() { in ThreadMain()