| /external/guava/guava-tests/test/com/google/common/collect/ |
| D | QueuesTest.java | 74 ? Queues.drain(q, buffer, maxElements, timeout, unit) in drain()
75 : Queues.drainUninterruptibly(q, buffer, maxElements, timeout, unit); in drain()
109 assertEquals(0, Queues.drain(q, ImmutableList.of(), 1, 10, TimeUnit.MILLISECONDS)); in testDrainTimesOut()
163 int elements = Queues.drain(q, buf, -1, Long.MAX_VALUE, TimeUnit.NANOSECONDS); in testNegativeMaxElements()
169 Queues.drain(q, buf, 1, Long.MAX_VALUE, TimeUnit.NANOSECONDS); in testNegativeMaxElements()
181 Queues.drain(q, ImmutableList.of(), 100, Long.MAX_VALUE, TimeUnit.NANOSECONDS); in testDrain_throws()
204 Queues.drainUninterruptibly(q, buf, 100, Long.MAX_VALUE, TimeUnit.NANOSECONDS); in testDrainUninterruptibly_doesNotThrow()
213 Queues.newLinkedBlockingDeque(0); in testNewLinkedBlockingDequeCapacity()
218 assertEquals(1, Queues.newLinkedBlockingDeque(1).remainingCapacity()); in testNewLinkedBlockingDequeCapacity()
219 assertEquals(11, Queues.newLinkedBlockingDeque(11).remainingCapacity()); in testNewLinkedBlockingDequeCapacity()
[all …]
|
| /external/guava/guava/src/com/google/common/util/concurrent/ |
| D | ListenerCallQueue.java | 22 import com.google.common.collect.Queues;
62 @GuardedBy("this") private final Queue<Callback<L>> waitQueue = Queues.newArrayDeque();
|
| D | MoreExecutors.java | 27 import com.google.common.collect.Queues;
679 BlockingQueue<Future<T>> futureQueue = Queues.newLinkedBlockingQueue(); in invokeAnyImpl()
|
| D | Futures.java | 35 import com.google.common.collect.Queues;
1180 Queues.newConcurrentLinkedQueue();
|
| /external/python/cpython3/Doc/library/ |
| D | asyncio-api-index.rst | 73 Queues chapter
76 Queues should be used to distribute work amongst multiple asyncio Tasks,
99 * See also the :ref:`Queues documentation page <asyncio-queues>`.
|
| D | asyncio-queue.rst | 6 Queues title
145 Queues can be used to distribute workload between several
|
| D | multiprocessing.rst | 203 **Queues**
220 Queues are thread and process safe.
666 Pipes and Queues
|
| /external/guava/guava-tests/test/com/google/common/util/concurrent/ |
| D | SerializingExecutorTest.java | 21 import com.google.common.collect.Queues;
43 Queue<Runnable> tasks = Queues.newArrayDeque();
|
| /external/guava/guava/src/com/google/common/collect/ |
| D | Queues.java | 41 public final class Queues { class
42 private Queues() {} in Queues() method in Queues
|
| /external/deqp/external/vulkancts/modules/vulkan/synchronization/ |
| D | vktSynchronizationInternallySynchronizedObjectsTests.cpp | 82 } Queues; typedef in vkt::synchronization::__anone4a9572f0111::MultiQueues
88 Queues temp; in addQueueFamilyIndex()
99 map<deUint32,Queues>::iterator it = m_queues.begin(); in getQueueFamilyIndex()
109 Queues & getQueues (const int index) in getQueues()
111 map<deUint32,Queues>::iterator it = m_queues.begin(); in getQueues()
120 Queues& queue = m_queues[getQueueFamilyIndex(queueFamilyIndexNdx)]; in getFreeQueue()
159 map<deUint32,Queues> m_queues;
|
| D | vktSynchronizationBasicSemaphoreTests.cpp | 158 struct Queues in basicMultiQueueCase() struct
174 Queues queues[COUNT] = in basicMultiQueueCase()
|
| /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/grpc-grpc/doc/cpp/ |
| D | perf_notes.md | 26 ## Completion Queues and Threading in the Async API
|
| /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;
285 final ConcurrentLinkedQueue<SettableFuture<T>> delegates = Queues.newConcurrentLinkedQueue(); in inCompletionOrder()
|
| /external/ltp/testcases/open_posix_testsuite/Documentation/ |
| D | COVERAGE.mqueues | 1 Coverage-Area: Message Queues (MSG)
|
| /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).
|
| D | NEWS | 19 …NPTL enabled) and linux-2.6.5-mm6 kernel.It is noted that "POSIX Message Queues" has been integrat…
|
| /external/grpc-grpc-java/interop-testing/src/main/java/io/grpc/testing/integration/ |
| D | TestServiceImpl.java | 20 import com.google.common.collect.Queues;
280 this.chunks = Queues.newLinkedBlockingQueue();
|
| /external/iproute2/examples/diffserv/ |
| D | regression-testing | 13 to the correct Virtual Queues.
|
| /external/python/cpython3/Doc/tutorial/ |
| D | datastructures.rst | 161 Using Lists as Queues
|
| /external/python/cpython2/Doc/tutorial/ |
| D | datastructures.rst | 146 Using Lists as Queues
|
| /external/python/cpython2/Doc/library/ |
| D | multiprocessing.rst | 94 **Queues**
111 Queues are thread and process safe.
499 Pipes and Queues
|
| /external/tensorflow/tensorflow/core/grappler/costs/ |
| D | graph_properties_test.cc | 435 TEST_F(GraphPropertiesTest, Queues) { in TEST_F() argument
|