| /external/guava/guava-tests/test/com/google/common/collect/ |
| D | QueuesTest.java | 92 ? Queues.drain(q, buffer, maxElements, timeout, unit) in drain()
93 : Queues.drainUninterruptibly(q, buffer, maxElements, timeout, unit); in drain()
131 assertEquals(0, Queues.drain(q, ImmutableList.of(), 1, 10, MILLISECONDS)); in testDrainTimesOut()
189 int elements = Queues.drain(q, buf, -1, MAX_VALUE, NANOSECONDS); in testNegativeMaxElements()
207 Queues.drain(q, ImmutableList.of(), 100, MAX_VALUE, NANOSECONDS); in testDrain_throws()
234 int elements = Queues.drainUninterruptibly(q, buf, 100, MAX_VALUE, NANOSECONDS); in testDrainUninterruptibly_doesNotThrow()
243 Queues.newLinkedBlockingDeque(0); in testNewLinkedBlockingDequeCapacity()
248 assertEquals(1, Queues.newLinkedBlockingDeque(1).remainingCapacity()); in testNewLinkedBlockingDequeCapacity()
249 assertEquals(11, Queues.newLinkedBlockingDeque(11).remainingCapacity()); in testNewLinkedBlockingDequeCapacity()
254 Queues.newLinkedBlockingQueue(0); in testNewLinkedBlockingQueueCapacity()
[all …]
|
| /external/guava/android/guava-tests/test/com/google/common/collect/ |
| D | QueuesTest.java | 92 ? Queues.drain(q, buffer, maxElements, timeout, unit) in drain()
93 : Queues.drainUninterruptibly(q, buffer, maxElements, timeout, unit); in drain()
131 assertEquals(0, Queues.drain(q, ImmutableList.of(), 1, 10, MILLISECONDS)); in testDrainTimesOut()
189 int elements = Queues.drain(q, buf, -1, MAX_VALUE, NANOSECONDS); in testNegativeMaxElements()
207 Queues.drain(q, ImmutableList.of(), 100, MAX_VALUE, NANOSECONDS); in testDrain_throws()
233 int elements = Queues.drainUninterruptibly(q, buf, 100, MAX_VALUE, NANOSECONDS); in testDrainUninterruptibly_doesNotThrow()
242 Queues.newLinkedBlockingDeque(0); in testNewLinkedBlockingDequeCapacity()
247 assertEquals(1, Queues.newLinkedBlockingDeque(1).remainingCapacity()); in testNewLinkedBlockingDequeCapacity()
248 assertEquals(11, Queues.newLinkedBlockingDeque(11).remainingCapacity()); in testNewLinkedBlockingDequeCapacity()
253 Queues.newLinkedBlockingQueue(0); in testNewLinkedBlockingQueueCapacity()
[all …]
|
| /external/guava/android/guava/src/com/google/common/eventbus/ |
| D | Dispatcher.java | 19 import com.google.common.collect.Queues;
82 return Queues.newArrayDeque();
152 Queues.newConcurrentLinkedQueue();
|
| /external/guava/guava/src/com/google/common/eventbus/ |
| D | Dispatcher.java | 19 import com.google.common.collect.Queues;
82 return Queues.newArrayDeque();
152 Queues.newConcurrentLinkedQueue();
|
| /external/guava/guava/src/com/google/common/util/concurrent/ |
| D | ListenerCallQueue.java | 21 import com.google.common.collect.Queues;
136 final Queue<ListenerCallQueue.Event<L>> waitQueue = Queues.newArrayDeque();
139 final Queue<Object> labelQueue = Queues.newArrayDeque();
|
| /external/guava/android/guava/src/com/google/common/util/concurrent/ |
| D | ListenerCallQueue.java | 21 import com.google.common.collect.Queues;
136 final Queue<ListenerCallQueue.Event<L>> waitQueue = Queues.newArrayDeque();
139 final Queue<Object> labelQueue = Queues.newArrayDeque();
|
| /external/llvm-project/lldb/source/Target/ |
| D | QueueList.cpp | 49 for (QueueSP queue_sp : Queues()) { in FindQueueByID()
60 for (QueueSP queue_sp : Queues()) { in FindQueueByIndexID()
|
| /external/python/cpython3/Doc/library/ |
| D | asyncio-api-index.rst | 76 Queues chapter
79 Queues should be used to distribute work amongst multiple asyncio Tasks,
102 * See also the :ref:`Queues documentation page <asyncio-queues>`.
|
| D | asyncio-queue.rst | 6 Queues title
153 Queues can be used to distribute workload between several
|
| /external/guava/android/guava-tests/test/com/google/common/eventbus/ |
| D | DispatcherTest.java | 22 import com.google.common.collect.Queues;
56 Queues.newConcurrentLinkedQueue();
|
| /external/guava/guava-tests/test/com/google/common/eventbus/ |
| D | DispatcherTest.java | 22 import com.google.common.collect.Queues;
56 Queues.newConcurrentLinkedQueue();
|
| /external/llvm-project/lldb/include/lldb/Target/ |
| D | QueueList.h | 60 QueueIterable Queues() { return QueueIterable(m_queues, m_mutex); } in Queues() function
|
| /external/antlr/runtime/ActionScript/project/src/org/antlr/runtime/tree/ |
| D | RewriteRuleNodeStream.as | 4 /** Queues up nodes matched on left side of -> in a tree parser. This is
|
| /external/deqp/external/vulkancts/modules/vulkan/synchronization/ |
| D | vktSynchronizationInternallySynchronizedObjectsTests.cpp | 84 } Queues; typedef in vkt::synchronization::__anon7ddd96cd0111::MultiQueues
90 Queues temp; in addQueueFamilyIndex()
101 map<deUint32,Queues>::iterator it = m_queues.begin(); in getQueueFamilyIndex()
111 Queues & getQueues (const int index) in getQueues()
113 map<deUint32,Queues>::iterator it = m_queues.begin(); in getQueues()
122 Queues& queue = m_queues[getQueueFamilyIndex(queueFamilyIndexNdx)]; in getFreeQueue()
161 map<deUint32,Queues> m_queues;
|
| /external/guava/android/guava/src/com/google/common/collect/ |
| D | Queues.java | 44 public final class Queues { class
45 private Queues() {} in Queues() method in Queues
|
| /external/guava/guava/src/com/google/common/collect/ |
| D | Queues.java | 44 public final class Queues { class
45 private Queues() {} in Queues() method in Queues
|
| /external/pigweed/pw_target_runner/pw_target_runner_protos/ |
| D | target_runner.proto | 21 // Queues a single executable, blocking until it has run.
|
| /external/guava/android/guava-tests/test/com/google/common/util/concurrent/ |
| D | SequentialExecutorTest.java | 25 import com.google.common.collect.Queues;
49 Queue<Runnable> tasks = Queues.newArrayDeque();
|
| /external/guava/guava-tests/test/com/google/common/util/concurrent/ |
| D | SequentialExecutorTest.java | 25 import com.google.common.collect.Queues;
49 Queue<Runnable> tasks = Queues.newArrayDeque();
|
| /external/grpc-grpc/doc/cpp/ |
| D | perf_notes.md | 26 ## Completion Queues and Threading in the Async API
|
| /external/ltp/testcases/open_posix_testsuite/Documentation/ |
| D | COVERAGE.mqueues | 1 Coverage-Area: Message Queues (MSG)
|
| /external/caliper/caliper/src/main/java/com/google/caliper/runner/ |
| D | StreamService.java | 28 import com.google.common.collect.Queues;
90 private final BlockingQueue<StreamItem> outputQueue = Queues.newLinkedBlockingQueue();
|
| D | ExperimentingCaliperRun.java | 31 import com.google.common.collect.Queues;
284 final ConcurrentLinkedQueue<SettableFuture<T>> delegates = Queues.newConcurrentLinkedQueue(); in inCompletionOrder()
|
| /external/ltp/testcases/open_posix_testsuite/ |
| D | BUILD | 34 Message Queues
106 Message Queues
|
| D | QUICK-START | 17 (Signals, Semaphores, Threads, Timers or Message Queues).
|