Searched refs:mThreads (Results 1 – 5 of 5) sorted by relevance
334 Impl(int numInitialThreads) : mThreads(numInitialThreads) { in Impl()335 for (size_t i = 0; i < mThreads.size(); ++i) { in Impl()336 mThreads[i].reset(new WorkPoolThread); in Impl()349 for (size_t i = 0; i < mThreads.size(); ++i) { in schedule()352 bool cleanup = mThreads[i]->shouldCleanupWaitGroup(&handle, &waitGroup); in schedule()368 for (size_t i = 0; i < mThreads.size(); ++i) { in schedule()369 if (!mThreads[i]->acquire()) continue; in schedule()374 mThreads.resize(mThreads.size() + 1); in schedule()375 mThreads[mThreads.size() - 1].reset(new WorkPoolThread); in schedule()381 mThreads[threadIndices[i]]->run(resHandle, waitGroup, tasks[i]); in schedule()[all …]
33 mThreads.reserve(2); in GnssNavigationMessageInterface()68 mThreads.emplace_back(std::thread([this]() { in start()93 for (auto iter = mThreads.begin(); iter != mThreads.end();) { in stop()104 iter = mThreads.erase(iter); in stop()
39 mThreads.reserve(2); in GnssMeasurementInterface()109 mThreads.emplace_back(std::thread([this, enableCorrVecOutputs, enableFullTracking]() { in start()149 for (auto iter = mThreads.begin(); iter != mThreads.end();) { in stop()160 iter = mThreads.erase(iter); in stop()
43 std::vector<std::thread> mThreads; member
55 std::vector<std::thread> mThreads; member