Searched defs:worker (Results 1 – 9 of 9) sorted by relevance
94 for (auto *worker : workers_) { in Initialize() local98 for (auto *worker : workers_) { in Initialize() local120 bool TaskScheduler::FillWithTasks(WorkerThread *worker) in FillWithTasks()161 size_t TaskScheduler::PutTasksInWorker(WorkerThread *worker, TaskQueueId selectedQueue) in PutTasksInWorker()194 for (auto *worker : workers_) { in AreWorkersEmpty() local317 for (auto *worker : workers_) { in Finalize() local320 for (auto *worker : workers_) { in Finalize() local
134 for (auto *worker : workers) { in RegisterAllWorkersInLocalQueue() local
325 for (auto worker : workers_) { in WaitForWorkers() local360 auto worker = allocator_->New<std::thread>(WorkerEntry, this, proc, i); in CreateNewThread() local
222 …explicit SuspendUpdateRemsetWorkerScope(UpdateRemsetWorker<LanguageConfig> *worker) : worker_(work… in SuspendUpdateRemsetWorkerScope()
507 for (auto *worker : workers_) { in DumpCoroutineStats() local550 for (auto *worker : workers_) { in MainCoroutineCompleted() local579 for (auto *worker : workers_) { in MainCoroutineCompleted() local
189 void StackfulCoroutineWorker::ScheduleLoopProxy(void *worker) in ScheduleLoopProxy()
253 Worker worker; in Main() local
260 …auto *worker = runtime.GetInternalAllocator()->New<std::thread>(Worker, &queue, &lock, i, &result); in RunVerifier() local
687 std::thread worker([&allocateObjects, &vec1] { in TEST_F() local