Searched refs:mJobQueue (Results 1 – 3 of 3) sorted by relevance
33 private final Queue<Runnable> mJobQueue; field in DispatchThread40 mJobQueue = new LinkedList<Runnable>(); in DispatchThread()56 synchronized (mJobQueue) { in runJob()57 if (mJobQueue.size() == MAX_MESSAGE_QUEUE_LENGTH) { in runJob()61 mJobQueue.add(job); in runJob()62 mJobQueue.notifyAll(); in runJob()97 synchronized(mJobQueue) { in end()98 mJobQueue.notifyAll(); in end()110 synchronized (mJobQueue) { in run()111 while (mJobQueue.size() == 0 && !isEnded()) { in run()[all …]
371 mJobQueue.reserve(16); in IncrementalService()2046 auto& existingJobs = mJobQueue[ifs->mountId]; in configureNativeBinaries()2131 (mPendingJobsMount != mount && mJobQueue.find(mount) == mJobQueue.end()); in waitForNativeBinariesExtraction()2291 mJobCondition.wait(lock, [this]() { return !mRunning || !mJobQueue.empty(); }); in runJobProcessing()2296 auto it = mJobQueue.begin(); in runJobProcessing()2299 mJobQueue.erase(it); in runJobProcessing()
510 std::unordered_map<MountId, std::vector<Job>> mJobQueue; variable