Home
last modified time | relevance | path

Searched refs:BlockingQueue (Results 1 – 25 of 25) sorted by relevance

/frameworks/native/services/inputflinger/tests/
DBlockingQueue_test.cpp33 BlockingQueue<int> queue(capacity); in TEST()
44 BlockingQueue<int> queue(capacity); in TEST()
59 BlockingQueue<int> queue(capacity); in TEST()
71 BlockingQueue<int> queue(capacity); in TEST()
83 BlockingQueue<int> queue(capacity); in TEST()
100 BlockingQueue<int> queue(capacity); in TEST()
125 BlockingQueue<int> queue(capacity); in TEST()
/frameworks/base/services/tests/servicestests/src/com/android/server/adb/
DAdbDebuggingManagerTestActivity.java27 import java.util.concurrent.BlockingQueue;
43 private static BlockingQueue sBlockingQueue;
137 public Configurator setBlockingQueue(BlockingQueue blockingQueue) { in setBlockingQueue()
DAdbDebuggingManagerTest.java45 import java.util.concurrent.BlockingQueue;
80 private BlockingQueue<TestResult> mBlockingQueue;
/frameworks/base/packages/SystemUI/tests/src/com/android/systemui/statusbar/policy/
DBlockingQueueIntentReceiver.java22 import java.util.concurrent.BlockingQueue;
27 private final BlockingQueue<Intent> mQueue = new ArrayBlockingQueue<Intent>(1);
/frameworks/base/tests/RollbackTest/RollbackTest/src/com/android/tests/rollback/
DLocalIntentSender.java27 import java.util.concurrent.BlockingQueue;
37 private static final BlockingQueue<Intent> sIntentSenderResults = new LinkedBlockingQueue<>();
DRollbackBroadcastReceiver.java27 import java.util.concurrent.BlockingQueue;
39 private final BlockingQueue<Intent> mRollbackBroadcasts = new LinkedBlockingQueue<>();
DRollbackTestUtils.java50 import java.util.concurrent.BlockingQueue;
410 BlockingQueue<PackageInstaller.SessionInfo> sessionStatus = new LinkedBlockingQueue<>(); in waitForSessionReady()
471 BlockingQueue<String> resultQueue = new LinkedBlockingQueue<>(); in processUserData()
519 BlockingQueue<Integer> crashQueue = new SynchronousQueue<>(); in sendCrashBroadcast()
/frameworks/base/core/tests/coretests/src/android/os/
DBinderWorkSourceNestedService.java25 import java.util.concurrent.BlockingQueue;
52 BlockingQueue<IBinderWorkSourceService> blockingQueue =
/frameworks/native/services/inputflinger/
DBlockingQueue.h35 class BlockingQueue {
37 BlockingQueue(size_t capacity) : mCapacity(capacity) { in BlockingQueue() function
DInputClassifier.h155 BlockingQueue<ClassifierEvent> mEvents;
/frameworks/base/packages/Shell/tests/src/com/android/shell/
DActionSendMultipleConsumerActivity.java19 import java.util.concurrent.BlockingQueue;
90 private final BlockingQueue<Bundle> mQueue = new SynchronousQueue<>();
/frameworks/base/tests/ActivityManagerPerfTests/tests/src/com/android/frameworks/perftests/am/util/
DTimeReceiver.java23 import java.util.concurrent.BlockingQueue;
36 private BlockingQueue<ReceivedMessage> mQueue = new LinkedBlockingQueue<>();
/frameworks/base/apct-tests/perftests/autofill/src/android/view/autofill/
DMyAutofillCallback.java25 import java.util.concurrent.BlockingQueue;
47 private final BlockingQueue<MyEvent> mEvents = new LinkedBlockingQueue<>(2);
DMyAutofillService.java37 import java.util.concurrent.BlockingQueue;
52 private static final BlockingQueue<FillRequest> sFillRequests = new LinkedBlockingQueue<>();
53 private static final BlockingQueue<CannedResponse> sCannedResponses =
/frameworks/base/services/core/java/com/android/server/pm/
DParallelPackageParser.java30 import java.util.concurrent.BlockingQueue;
52 private final BlockingQueue<ParseResult> mQueue = new ArrayBlockingQueue<>(QUEUE_CAPACITY);
/frameworks/base/tests/AmSlam/src/test/amslam/
DMainActivity.java31 import java.util.concurrent.BlockingQueue;
38 private static final BlockingQueue<Intent> sWorkQueue = new ArrayBlockingQueue<>(100);
/frameworks/layoutlib/remote/server/src/com/android/layoutlib/bridge/remote/server/
DServerMain.java38 import java.util.concurrent.BlockingQueue;
124 BlockingQueue<String> outputQueue = new ArrayBlockingQueue<>(10); in forkAndStartServer()
/frameworks/base/keystore/java/android/security/
DKeyChain.java58 import java.util.concurrent.BlockingQueue;
794 final BlockingQueue<IKeyChainService> q = new LinkedBlockingQueue<IKeyChainService>(1); in bindAsUser()
/frameworks/base/services/core/java/com/android/server/
DNativeDaemonConnector.java45 import java.util.concurrent.BlockingQueue;
615 public BlockingQueue<NativeDaemonEvent> responses =
/frameworks/opt/net/ims/src/java/com/android/ims/
DImsManager.java69 import java.util.concurrent.BlockingQueue;
2181 BlockingQueue<Boolean> result = new LinkedBlockingDeque<>(1); in queryMmTelCapability()
/frameworks/opt/setupwizard/tools/docs/
Dandroid-22.txt49071 …Queue extends java.util.AbstractQueue implements java.util.concurrent.BlockingQueue java.io.Serial…
49089 …public abstract interface BlockingDeque implements java.util.concurrent.BlockingQueue java.util.De…
49121 public abstract interface BlockingQueue implements java.util.Queue {
49356 …ic class DelayQueue extends java.util.AbstractQueue implements java.util.concurrent.BlockingQueue {
49396 …CompletionService(java.util.concurrent.Executor, java.util.concurrent.BlockingQueue<java.util.conc…
49596 …Queue extends java.util.AbstractQueue implements java.util.concurrent.BlockingQueue java.io.Serial…
49660 …Queue extends java.util.AbstractQueue implements java.util.concurrent.BlockingQueue java.io.Serial…
49766 …Queue extends java.util.AbstractQueue implements java.util.concurrent.BlockingQueue java.io.Serial…
49797 …r(int, int, long, java.util.concurrent.TimeUnit, java.util.concurrent.BlockingQueue<java.lang.Runn…
49798 …r(int, int, long, java.util.concurrent.TimeUnit, java.util.concurrent.BlockingQueue<java.lang.Runn…
[all …]
/frameworks/base/config/
Dpreloaded-classes6704 java.util.concurrent.BlockingQueue
Dboot-image-profile.txt29811 …hreadPoolExecutor;-><init>(IIJLjava/util/concurrent/TimeUnit;Ljava/util/concurrent/BlockingQueue;)V
29812 …utor;-><init>(IIJLjava/util/concurrent/TimeUnit;Ljava/util/concurrent/BlockingQueue;Ljava/util/con…
29813 …utor;-><init>(IIJLjava/util/concurrent/TimeUnit;Ljava/util/concurrent/BlockingQueue;Ljava/util/con…
29824 HSPLjava/util/concurrent/ThreadPoolExecutor;->getQueue()Ljava/util/concurrent/BlockingQueue;
39765 Ljava/util/concurrent/BlockingQueue;
Dhiddenapi-greylist-max-o.txt51995 Landroid/os/AsyncTask;->sPoolWorkQueue:Ljava/util/concurrent/BlockingQueue;
116118 …QueueingFuture;-><init>(Ljava/util/concurrent/RunnableFuture;Ljava/util/concurrent/BlockingQueue;)V
116119 …ent/ExecutorCompletionService$QueueingFuture;->completionQueue:Ljava/util/concurrent/BlockingQueue;
116122 …va/util/concurrent/ExecutorCompletionService;->completionQueue:Ljava/util/concurrent/BlockingQueue;
117073 Ljava/util/concurrent/ThreadPoolExecutor;->workQueue:Ljava/util/concurrent/BlockingQueue;
/frameworks/base/api/
Dcurrent.txt70923 …E> extends java.util.AbstractQueue<E> implements java.util.concurrent.BlockingQueue<E> java.io.Ser…
70941 …public interface BlockingDeque<E> extends java.util.concurrent.BlockingQueue<E> java.util.Deque<E>…
70952 public interface BlockingQueue<E> extends java.util.Queue<E> {
71371 …rent.Delayed> extends java.util.AbstractQueue<E> implements java.util.concurrent.BlockingQueue<E> {
71411 …CompletionService(java.util.concurrent.Executor, java.util.concurrent.BlockingQueue<java.util.conc…
71623 …E> extends java.util.AbstractQueue<E> implements java.util.concurrent.BlockingQueue<E> java.io.Ser…
71687 …E> extends java.util.AbstractQueue<E> implements java.util.concurrent.BlockingQueue<E> java.io.Ser…
71792 …E> extends java.util.AbstractQueue<E> implements java.util.concurrent.BlockingQueue<E> java.io.Ser…
71823 …r(int, int, long, java.util.concurrent.TimeUnit, java.util.concurrent.BlockingQueue<java.lang.Runn…
71824 …r(int, int, long, java.util.concurrent.TimeUnit, java.util.concurrent.BlockingQueue<java.lang.Runn…
[all …]