Searched refs:mJobQueue (Results 1 – 4 of 4) sorted by relevance
32 private final Queue<Runnable> mJobQueue; field in DispatchThread39 mJobQueue = new LinkedList<Runnable>(); in DispatchThread()55 synchronized (mJobQueue) { 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()116 mJobQueue.wait(); in run()[all …]
88 private JobQueue mJobQueue; field in BuiltInPrintService140 mJobQueue = new JobQueue(); in onCreate()168 mJobQueue.print(new LocalPrintJob(this, mBackend, printJob)); in onPrintJobQueued()174 mJobQueue.cancel(printJob.getId()); in onRequestCancelPrintJob()372 mJobQueue.restart(printerId); in onStartCommand()377 mJobQueue.cancel(printerId); in onStartCommand()
366 mJobQueue.reserve(16); in IncrementalService()2026 auto& existingJobs = mJobQueue[ifs->mountId]; in configureNativeBinaries()2111 (mPendingJobsMount != mount && mJobQueue.find(mount) == mJobQueue.end()); in waitForNativeBinariesExtraction()2271 mJobCondition.wait(lock, [this]() { return !mRunning || !mJobQueue.empty(); }); in runJobProcessing()2276 auto it = mJobQueue.begin(); in runJobProcessing()2279 mJobQueue.erase(it); in runJobProcessing()
510 std::unordered_map<MountId, std::vector<Job>> mJobQueue; variable