Home
last modified time | relevance | path

Searched refs:BlockingQueue (Results 1 – 23 of 23) 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/native/services/inputflinger/
DBlockingQueue.h35 class BlockingQueue {
37 BlockingQueue(size_t capacity) : mCapacity(capacity) { in BlockingQueue() function
DInputClassifier.h150 BlockingQueue<ClassifierEvent> mEvents;
/frameworks/base/core/tests/coretests/src/android/os/
DBinderWorkSourceNestedService.java25 import java.util.concurrent.BlockingQueue;
52 BlockingQueue<IBinderWorkSourceService> blockingQueue =
/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/
DMyAutofillService.java37 import java.util.concurrent.BlockingQueue;
52 private static final BlockingQueue<FillRequest> sFillRequests = new LinkedBlockingQueue<>();
53 private static final BlockingQueue<CannedResponse> sCannedResponses =
DMyAutofillCallback.java25 import java.util.concurrent.BlockingQueue;
47 private final BlockingQueue<MyEvent> mEvents = new LinkedBlockingQueue<>(2);
/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;
804 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;
616 public BlockingQueue<NativeDaemonEvent> responses =
/frameworks/opt/net/ims/src/java/com/android/ims/
DImsManager.java72 import java.util.concurrent.BlockingQueue;
2105 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-classes6701 java.util.concurrent.BlockingQueue
Dboot-image-profile.txt29810 …hreadPoolExecutor;-><init>(IIJLjava/util/concurrent/TimeUnit;Ljava/util/concurrent/BlockingQueue;)V
29811 …utor;-><init>(IIJLjava/util/concurrent/TimeUnit;Ljava/util/concurrent/BlockingQueue;Ljava/util/con…
29812 …utor;-><init>(IIJLjava/util/concurrent/TimeUnit;Ljava/util/concurrent/BlockingQueue;Ljava/util/con…
29823 HSPLjava/util/concurrent/ThreadPoolExecutor;->getQueue()Ljava/util/concurrent/BlockingQueue;
39764 Ljava/util/concurrent/BlockingQueue;
Dhiddenapi-greylist-max-o.txt48497 Landroid/os/AsyncTask;->sPoolWorkQueue:Ljava/util/concurrent/BlockingQueue;
108804 …QueueingFuture;-><init>(Ljava/util/concurrent/RunnableFuture;Ljava/util/concurrent/BlockingQueue;)V
108805 …ent/ExecutorCompletionService$QueueingFuture;->completionQueue:Ljava/util/concurrent/BlockingQueue;
108808 …va/util/concurrent/ExecutorCompletionService;->completionQueue:Ljava/util/concurrent/BlockingQueue;
109679 Ljava/util/concurrent/ThreadPoolExecutor;->workQueue:Ljava/util/concurrent/BlockingQueue;
/frameworks/base/non-updatable-api/
Dcurrent.txt72330 …E> extends java.util.AbstractQueue<E> implements java.util.concurrent.BlockingQueue<E> java.io.Ser…
72348 …public interface BlockingDeque<E> extends java.util.concurrent.BlockingQueue<E> java.util.Deque<E>…
72359 public interface BlockingQueue<E> extends java.util.Queue<E> {
72778 …rent.Delayed> extends java.util.AbstractQueue<E> implements java.util.concurrent.BlockingQueue<E> {
72818 …CompletionService(java.util.concurrent.Executor, java.util.concurrent.BlockingQueue<java.util.conc…
73053 …E> extends java.util.AbstractQueue<E> implements java.util.concurrent.BlockingQueue<E> java.io.Ser…
73117 …E> extends java.util.AbstractQueue<E> implements java.util.concurrent.BlockingQueue<E> java.io.Ser…
73222 …E> extends java.util.AbstractQueue<E> implements java.util.concurrent.BlockingQueue<E> java.io.Ser…
73253 …r(int, int, long, java.util.concurrent.TimeUnit, java.util.concurrent.BlockingQueue<java.lang.Runn…
73254 …r(int, int, long, java.util.concurrent.TimeUnit, java.util.concurrent.BlockingQueue<java.lang.Runn…
[all …]
/frameworks/base/api/
Dcurrent.txt72474 …E> extends java.util.AbstractQueue<E> implements java.util.concurrent.BlockingQueue<E> java.io.Ser…
72492 …public interface BlockingDeque<E> extends java.util.concurrent.BlockingQueue<E> java.util.Deque<E>…
72503 public interface BlockingQueue<E> extends java.util.Queue<E> {
72922 …rent.Delayed> extends java.util.AbstractQueue<E> implements java.util.concurrent.BlockingQueue<E> {
72962 …CompletionService(java.util.concurrent.Executor, java.util.concurrent.BlockingQueue<java.util.conc…
73197 …E> extends java.util.AbstractQueue<E> implements java.util.concurrent.BlockingQueue<E> java.io.Ser…
73261 …E> extends java.util.AbstractQueue<E> implements java.util.concurrent.BlockingQueue<E> java.io.Ser…
73366 …E> extends java.util.AbstractQueue<E> implements java.util.concurrent.BlockingQueue<E> java.io.Ser…
73397 …r(int, int, long, java.util.concurrent.TimeUnit, java.util.concurrent.BlockingQueue<java.lang.Runn…
73398 …r(int, int, long, java.util.concurrent.TimeUnit, java.util.concurrent.BlockingQueue<java.lang.Runn…
[all …]