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() local322 for (auto *worker : workers_) { in Finalize() local325 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
522 for (auto *worker : workers_) { in DumpCoroutineStats() local565 for (auto *worker : workers_) { in MainCoroutineCompleted() local594 for (auto *worker : workers_) { in MainCoroutineCompleted() local616 auto *worker = co->GetContext<StackfulCoroutineContext>()->GetWorker(); in IsMainWorker() local
189 void StackfulCoroutineWorker::ScheduleLoopProxy(void *worker) in ScheduleLoopProxy()
222 …explicit SuspendUpdateRemsetWorkerScope(UpdateRemsetWorker<LanguageConfig> *worker) : worker_(work… in SuspendUpdateRemsetWorkerScope()
253 Worker worker; in Main() local
296 …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