Searched refs:BlockingQueue (Results 1 – 24 of 24) sorted by relevance
33 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()
27 import java.util.concurrent.BlockingQueue;43 private static BlockingQueue sBlockingQueue;137 public Configurator setBlockingQueue(BlockingQueue blockingQueue) { in setBlockingQueue()
45 import java.util.concurrent.BlockingQueue;80 private BlockingQueue<TestResult> mBlockingQueue;
22 import java.util.concurrent.BlockingQueue;27 private final BlockingQueue<Intent> mQueue = new ArrayBlockingQueue<Intent>(1);
25 import java.util.concurrent.BlockingQueue;52 BlockingQueue<IBinderWorkSourceService> blockingQueue =
35 class BlockingQueue {37 BlockingQueue(size_t capacity) : mCapacity(capacity) { in BlockingQueue() function
150 BlockingQueue<ClassifierEvent> mEvents;
19 import java.util.concurrent.BlockingQueue;90 private final BlockingQueue<Bundle> mQueue = new SynchronousQueue<>();
23 import java.util.concurrent.BlockingQueue;36 private BlockingQueue<ReceivedMessage> mQueue = new LinkedBlockingQueue<>();
32 import java.util.concurrent.BlockingQueue;47 private final BlockingQueue<ParseResult> mQueue = new ArrayBlockingQueue<>(QUEUE_CAPACITY);
25 import java.util.concurrent.BlockingQueue;47 private final BlockingQueue<MyEvent> mEvents = new LinkedBlockingQueue<>(2);
37 import java.util.concurrent.BlockingQueue;52 private static final BlockingQueue<FillRequest> sFillRequests = new LinkedBlockingQueue<>();53 private static final BlockingQueue<CannedResponse> sCannedResponses =
34 import java.util.concurrent.BlockingQueue;118 private final BlockingQueue<Intent> mIntentSenderResults = new LinkedBlockingQueue<>();
31 import java.util.concurrent.BlockingQueue;38 private static final BlockingQueue<Intent> sWorkQueue = new ArrayBlockingQueue<>(100);
38 import java.util.concurrent.BlockingQueue;124 BlockingQueue<String> outputQueue = new ArrayBlockingQueue<>(10); in forkAndStartServer()
34 import java.util.concurrent.BlockingQueue;60 BlockingQueue<byte[]> mPacketQueue;
45 import java.util.concurrent.BlockingQueue;616 public BlockingQueue<NativeDaemonEvent> responses =
51 import java.util.concurrent.BlockingQueue;3011 private static final BlockingQueue<LinearBlock> sPool =
72 import java.util.concurrent.BlockingQueue;2105 BlockingQueue<Boolean> result = new LinkedBlockingDeque<>(1); in queryMmTelCapability()
META-INF/ META-INF/MANIFEST.MF javax/ javax/net/ javax/ ...
49071 …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 …]
74943 …E> extends java.util.AbstractQueue<E> implements java.util.concurrent.BlockingQueue<E> java.io.Ser…74961 …public interface BlockingDeque<E> extends java.util.concurrent.BlockingQueue<E> java.util.Deque<E>…74972 public interface BlockingQueue<E> extends java.util.Queue<E> {75391 …rent.Delayed> extends java.util.AbstractQueue<E> implements java.util.concurrent.BlockingQueue<E> {75431 …CompletionService(java.util.concurrent.Executor, java.util.concurrent.BlockingQueue<java.util.conc…75666 …E> extends java.util.AbstractQueue<E> implements java.util.concurrent.BlockingQueue<E> java.io.Ser…75730 …E> extends java.util.AbstractQueue<E> implements java.util.concurrent.BlockingQueue<E> java.io.Ser…75835 …E> extends java.util.AbstractQueue<E> implements java.util.concurrent.BlockingQueue<E> java.io.Ser…75866 …r(int, int, long, java.util.concurrent.TimeUnit, java.util.concurrent.BlockingQueue<java.lang.Runn…75867 …r(int, int, long, java.util.concurrent.TimeUnit, java.util.concurrent.BlockingQueue<java.lang.Runn…[all …]
11161 java.util.concurrent.BlockingQueue
37328 …hreadPoolExecutor;-><init>(IIJLjava/util/concurrent/TimeUnit;Ljava/util/concurrent/BlockingQueue;)V37329 …utor;-><init>(IIJLjava/util/concurrent/TimeUnit;Ljava/util/concurrent/BlockingQueue;Ljava/util/con…37330 …utor;-><init>(IIJLjava/util/concurrent/TimeUnit;Ljava/util/concurrent/BlockingQueue;Ljava/util/con…37331 …utor;-><init>(IIJLjava/util/concurrent/TimeUnit;Ljava/util/concurrent/BlockingQueue;Ljava/util/con…37347 HSPLjava/util/concurrent/ThreadPoolExecutor;->getQueue()Ljava/util/concurrent/BlockingQueue;52820 Ljava/util/concurrent/BlockingQueue;