Home
last modified time | relevance | path

Searched refs:workQueue (Results 1 – 14 of 14) sorted by relevance

/aosp12/packages/apps/UniversalMediaPlayer/java/com/android/pump/concurrent/
H A DUniqueExecutor.java37 @NonNull TimeUnit unit, @NonNull BlockingQueue<Runnable> workQueue) { in UniqueExecutor() argument
38 super(corePoolSize, maximumPoolSize, keepAliveTime, unit, workQueue); in UniqueExecutor()
42 @NonNull TimeUnit unit, @NonNull BlockingQueue<Runnable> workQueue, in UniqueExecutor() argument
44 super(corePoolSize, maximumPoolSize, keepAliveTime, unit, workQueue, threadFactory); in UniqueExecutor()
48 @NonNull TimeUnit unit, @NonNull BlockingQueue<Runnable> workQueue, in UniqueExecutor() argument
50 super(corePoolSize, maximumPoolSize, keepAliveTime, unit, workQueue, handler); in UniqueExecutor()
54 @NonNull TimeUnit unit, @NonNull BlockingQueue<Runnable> workQueue, in UniqueExecutor() argument
56 super(corePoolSize, maximumPoolSize, keepAliveTime, unit, workQueue, threadFactory, in UniqueExecutor()
/aosp12/frameworks/av/media/codec2/hidl/1.0/vts/functional/common/
H A Dmedia_c2_hidl_test_common.cpp69 std::mutex& queueLock, std::list<std::unique_ptr<C2Work>>& workQueue, in testInputBuffer() argument
75 if (!workQueue.empty()) { in testInputBuffer()
76 work.swap(workQueue.front()); in testInputBuffer()
77 workQueue.pop_front(); in testInputBuffer()
107 queueSize = workQueue.size(); in waitOnInputConsumption()
111 if (queueSize != workQueue.size()) { in waitOnInputConsumption()
112 queueSize = workQueue.size(); in waitOnInputConsumption()
125 std::list<std::unique_ptr<C2Work>>& workQueue, bool& eos, bool& csd, in workDone() argument
161 workQueue.push_back(std::move(work)); in workDone()
246 std::list<std::unique_ptr<C2Work>>& workQueue, in verifyFlushOutput() argument
[all …]
H A Dmedia_c2_hidl_test_common.h141 std::mutex& queueLock, std::list<std::unique_ptr<C2Work>>& workQueue,
145 std::list<std::unique_ptr<C2Work>>& workQueue,
151 std::list<std::unique_ptr<C2Work>>& workQueue, bool& eos, bool& csd,
160 std::list<std::unique_ptr<C2Work>>& workQueue,
/aosp12/packages/modules/GeoTZ/data_pipeline/src/main/java/com/android/timezone/location/data_pipeline/steps/
H A DMergeTzS2Ranges.java151 ArrayDeque<File> workQueue = new ArrayDeque<>(); in createCombinedTzS2Ranges() local
153 workQueue.addLast(tzS2RangesFile); in createCombinedTzS2Ranges()
159 while (!(workQueue.size() == 1 && resultFutureList.isEmpty())) { in createCombinedTzS2Ranges()
162 while (workQueue.size() > 1) { in createCombinedTzS2Ranges()
163 File leftFile = workQueue.removeFirst(); in createCombinedTzS2Ranges()
164 File rightFile = workQueue.removeFirst(); in createCombinedTzS2Ranges()
193 workQueue.add(result); in createCombinedTzS2Ranges()
207 return workQueue.removeFirst(); in createCombinedTzS2Ranges()
/aosp12/frameworks/base/tools/aapt/
H A DWorkQueue.cpp160 WorkQueue::WorkThread::WorkThread(WorkQueue* workQueue, bool canCallJava) : in WorkThread() argument
161 Thread(canCallJava), mWorkQueue(workQueue) { in WorkThread()
H A DWorkQueue.h91 WorkThread(WorkQueue* workQueue, bool canCallJava);
H A DResource.cpp1705 std::queue<CompileResourceWorkItem>& workQueue = table.getWorkQueue(); in buildResources() local
1706 while (!workQueue.empty()) { in buildResources()
1707 CompileResourceWorkItem& workItem = workQueue.front(); in buildResources()
1725 workQueue.pop(); in buildResources()
/aosp12/frameworks/av/media/codec2/hidl/1.0/vts/functional/audio/
H A DVtsHalMediaC2V1_0TargetAudioEncTest.cpp325 std::list<std::unique_ptr<C2Work>>& workQueue, in encodeNFrames() argument
352 if (!workQueue.empty()) { in encodeNFrames()
353 work.swap(workQueue.front()); in encodeNFrames()
354 workQueue.pop_front(); in encodeNFrames()
H A DVtsHalMediaC2V1_0TargetAudioDecTest.cpp318 std::list<std::unique_ptr<C2Work>>& workQueue, in decodeNFrames() argument
332 if (!workQueue.empty()) { in decodeNFrames()
333 work.swap(workQueue.front()); in decodeNFrames()
334 workQueue.pop_front(); in decodeNFrames()
/aosp12/frameworks/av/media/codec2/hidl/1.0/vts/functional/video/
H A DVtsHalMediaC2V1_0TargetVideoEncTest.cpp328 std::list<std::unique_ptr<C2Work>>& workQueue, in encodeNFrames() argument
351 if (!workQueue.empty()) { in encodeNFrames()
352 work.swap(workQueue.front()); in encodeNFrames()
353 workQueue.pop_front(); in encodeNFrames()
H A DVtsHalMediaC2V1_0TargetVideoDecTest.cpp438 std::list<std::unique_ptr<C2Work>>& workQueue, in decodeNFrames() argument
452 if (!workQueue.empty()) { in decodeNFrames()
453 work.swap(workQueue.front()); in decodeNFrames()
454 workQueue.pop_front(); in decodeNFrames()
/aosp12/packages/apps/Car/DebuggingRestrictionController/libs/
H A Dhttpcore-4.4.13.jarMETA-INF/MANIFEST.MF META-INF/ org/ org/apache/ org/ ...
/aosp12/frameworks/base/tools/aapt2/integration-tests/CommandTests/
H A Dandroid-28.jarMETA-INF/ META-INF/MANIFEST.MF javax/ javax/net/ javax/ ...
/aosp12/art/build/boot/hiddenapi/
H A Dhiddenapi-max-target-o-low-priority.txt7645 Ljava/util/concurrent/ForkJoinWorkerThread;->workQueue:Ljava/util/concurrent/ForkJoinPool$WorkQueue;
8288 Ljava/util/concurrent/ThreadPoolExecutor;->workQueue:Ljava/util/concurrent/BlockingQueue;