Searched refs:mJobQueue (Results 1 – 3 of 3) sorted by relevance
32 private final Queue<Runnable> mJobQueue; field in DispatchThread39 mJobQueue = new LinkedList<Runnable>(); in DispatchThread()55 synchronized (mJobQueue) { in runJob()56 if (mJobQueue.size() == MAX_MESSAGE_QUEUE_LENGTH) { in runJob()60 mJobQueue.add(job); in runJob()61 mJobQueue.notifyAll(); in runJob()98 synchronized(mJobQueue) { in end()99 mJobQueue.notifyAll(); in end()113 synchronized (mJobQueue) { in run()114 while (mJobQueue.size() == 0 && !isEnded()) { in run()[all …]
288 mJobQueue.reserve(16); in IncrementalService()1557 auto& existingJobs = mJobQueue[ifs->mountId]; in configureNativeBinaries()1670 (mPendingJobsMount != mount && mJobQueue.find(mount) == mJobQueue.end()); in waitForNativeBinariesExtraction()1683 mJobCondition.wait(lock, [this]() { return !mRunning || !mJobQueue.empty(); }); in runJobProcessing()1688 auto it = mJobQueue.begin(); in runJobProcessing()1691 mJobQueue.erase(it); in runJobProcessing()
381 std::unordered_map<MountId, std::vector<Job>> mJobQueue; variable