Searched refs:mWorkQueue (Results 1 – 7 of 7) sorted by relevance
67 if (mWorkQueue.empty()) return; in process()68 toProcess = std::move(mWorkQueue); in process()72 mWorkQueue.reserve(std::distance(moveBack, std::end(toProcess)) + 5); in process()73 std::move(moveBack, std::end(toProcess), std::back_inserter(mWorkQueue)); in process()113 if (mWorkQueue.empty()) { in nextWakeup()116 return std::begin(mWorkQueue)->runAt; in nextWakeup()126 std::begin(mWorkQueue), std::end(mWorkQueue), in enqueue()128 needsWakeup = std::begin(mWorkQueue) == insertAt; in enqueue()129 mWorkQueue.emplace(insertAt, std::move(item)); in enqueue()139 std::vector<WorkItem> mWorkQueue; variable
85 while (!mWorkQueue.hasSpace()) { in enqueue()90 mWorkQueue.push(std::move(task)); in enqueue()91 if (mWaitingThreads == THREAD_COUNT || (mWaitingThreads > 0 && mWorkQueue.size() > 1)) { in enqueue()99 if (!mWorkQueue.hasWork()) { in workerLoop()106 while (mWorkQueue.hasWork()) { in workerLoop()107 auto work = mWorkQueue.pop(); in workerLoop()
122 ArrayQueue<Task, QUEUE_SIZE> mWorkQueue; variable
161 Thread(canCallJava), mWorkQueue(workQueue) { in WorkThread()168 return mWorkQueue->threadLoop(); in threadLoop()
97 WorkQueue* const mWorkQueue; variable
130 return mWorkQueue; in getWorkQueue()638 std::queue<CompileResourceWorkItem> mWorkQueue; variable
4824 mWorkQueue.push(item); in versionForCompat()4959 mWorkQueue.push(item); in modifyForCompat()5233 mWorkQueue.push(workItem); in processBundleFormatImpl()