Searched refs:mThreads (Results 1 – 6 of 6) sorted by relevance
76 private final HashMap<Long, HashSet<Uri>> mThreads; field in PduCache82 mThreads = new HashMap<Long, HashSet<Uri>>(); in PduCache()107 HashSet<Uri> thread = mThreads.get(threadId); in put()110 mThreads.put(threadId, thread); in put()185 mThreads.clear(); in purgeAll()238 HashSet<Uri> thread = mThreads.get(entry.getThreadId()); in removeFromThreads()249 HashSet<Uri> thread = mThreads.remove(threadId); in purgeByThreadId()262 HashSet<Uri> msgBox = mThreads.get(Long.valueOf(entry.getMessageBox())); in removeFromMessageBoxes()
129 threads = std::move(mThreads); in quit()130 mThreads.clear(); in quit()148 for (auto it = mThreads.begin(); it != mThreads.end(); ) { in launch()151 it = mThreads.erase(it); in launch()157 const size_t threadCount = mThreads.size(); in launch()162 mThreads.emplace_back(std::make_unique<JavaThread>( in launch()193 std::list<std::unique_ptr<JavaThread>> mThreads GUARDED_BY(mThreadLock);
166 std::vector<std::thread> mThreads; member in NdkAsyncCodecFuzzer::ThreadPool195 mThreads.resize(numThreads); in start()197 mThreads.at(i) = std::thread(&ThreadPool::ThreadLoop, this); in start()231 for (std::thread& active_thread : mThreads) { in stop()234 mThreads.clear(); in stop()
104 private ArrayList<Thread> mThreads; field in UsbDirectMidiDevice327 mThreads = new ArrayList<Thread>(); in openLocked()518 mThreads.add(newThread); in openLocked()660 mThreads.add(newThread); in openLocked()738 for (Thread thread : mThreads) { in closeLocked()745 for (Thread thread : mThreads) { in closeLocked()755 mThreads = null; in closeLocked()
252 LOG_ALWAYS_FATAL_IF(!mConnections.mThreads.empty(), "Shutdown failed"); in shutdownAndWait()339 mConnections.mThreads[thread.get_id()] = std::move(thread); in preJoinThreadOwnership()449 auto it = session->mConnections.mThreads.find(rpc_this_thread::get_id()); in join()450 LOG_ALWAYS_FATAL_IF(it == session->mConnections.mThreads.end()); in join()452 session->mConnections.mThreads.erase(it); in join()
397 std::map<RpcMaybeThread::id, RpcMaybeThread> mThreads; member