Home
last modified time | relevance | path

Searched refs:SynchronousQueue (Results 1 – 17 of 17) sorted by relevance

/libcore/jsr166-tests/src/test/java/jsr166/
DSynchronousQueueTest.java22 import java.util.concurrent.SynchronousQueue;
61 final SynchronousQueue q = new SynchronousQueue(fair); in testEmptyFull()
74 SynchronousQueue q = new SynchronousQueue(fair); in testOffer()
84 SynchronousQueue q = new SynchronousQueue(fair); in testAdd()
98 SynchronousQueue q = new SynchronousQueue(fair); in testAddAll_self()
111 SynchronousQueue q = new SynchronousQueue(fair); in testAddAll_ISE()
128 final SynchronousQueue q = new SynchronousQueue(fair); in testBlockingPut()
160 final SynchronousQueue q = new SynchronousQueue(fair); in testPutWithTake()
194 final SynchronousQueue q = new SynchronousQueue(fair); in testTimedOffer()
220 final SynchronousQueue q = new SynchronousQueue(fair); in testPoll()
[all …]
DSynchronousQueueFairTest.java12 import java.util.concurrent.SynchronousQueue;
17 return new SynchronousQueue(true); in emptyCollection()
DSynchronousQueueNotFairTest.java12 import java.util.concurrent.SynchronousQueue;
17 return new SynchronousQueue(true); in emptyCollection()
DRecursiveActionTest.java19 import java.util.concurrent.SynchronousQueue;
340 final SynchronousQueue<FibAction[]> sq = in testJoinIgnoresInterruptsOutsideForkJoinPool()
341 new SynchronousQueue<FibAction[]>(); in testJoinIgnoresInterruptsOutsideForkJoinPool()
DThreadPoolExecutorTest.java30 import java.util.concurrent.SynchronousQueue;
56 super(1, 1, LONG_DELAY_MS, MILLISECONDS, new SynchronousQueue<Runnable>()); in ExtendedTPE()
DThreadPoolExecutorSubclassTest.java30 import java.util.concurrent.SynchronousQueue;
203 super(1, 1, LONG_DELAY_MS, MILLISECONDS, new SynchronousQueue<Runnable>()); in CustomTPE()
/libcore/ojluni/src/test/java/util/concurrent/tck/
DSynchronousQueueTest.java56 import java.util.concurrent.SynchronousQueue;
70 return new SynchronousQueue(true); in emptyCollection()
78 return new SynchronousQueue(false); in emptyCollection()
103 final SynchronousQueue q = new SynchronousQueue(fair); in testEmptyFull()
118 SynchronousQueue q = new SynchronousQueue(fair); in testOffer()
130 SynchronousQueue q = new SynchronousQueue(fair); in testAdd()
146 SynchronousQueue q = new SynchronousQueue(fair); in testAddAll_self()
161 SynchronousQueue q = new SynchronousQueue(fair); in testAddAll_ISE()
180 final SynchronousQueue q = new SynchronousQueue(fair); in testBlockingPut()
214 final SynchronousQueue q = new SynchronousQueue(fair); in testPutWithTake()
[all …]
DRecursiveActionTest.java53 import java.util.concurrent.SynchronousQueue;
376 final SynchronousQueue<FibAction[]> sq = in testJoinIgnoresInterruptsOutsideForkJoinPool()
377 new SynchronousQueue<FibAction[]>(); in testJoinIgnoresInterruptsOutsideForkJoinPool()
DJSR166TestCase.java124 import java.util.concurrent.SynchronousQueue;
2334 new SynchronousQueue<Runnable>());
DThreadPoolExecutorSubclassTest.java63 import java.util.concurrent.SynchronousQueue;
238 super(1, 1, LONG_DELAY_MS, MILLISECONDS, new SynchronousQueue<Runnable>()); in CustomTPE()
DThreadPoolExecutorTest.java64 import java.util.concurrent.SynchronousQueue;
92 super(1, 1, LONG_DELAY_MS, MILLISECONDS, new SynchronousQueue<Runnable>()); in ExtendedTPE()
/libcore/ojluni/src/main/java/java/util/concurrent/
DSynchronousQueue.java93 public class SynchronousQueue<E> extends AbstractQueue<E> class
239 public SynchronousQueue() { in SynchronousQueue() method in SynchronousQueue
249 public SynchronousQueue(boolean fair) { in SynchronousQueue() method in SynchronousQueue
586 return new SynchronousQueue<E>(waitingProducers instanceof FifoWaitQueue); in readResolve()
DExecutors.java224 new SynchronousQueue<Runnable>()); in newCachedThreadPool()
240 new SynchronousQueue<Runnable>(), in newCachedThreadPool()
/libcore/ojluni/src/test/java/util/Collections/
DEmptyIterator.java40 import java.util.concurrent.SynchronousQueue;
56 testEmptyCollection(new SynchronousQueue<Object>()); in test()
/libcore/
Dopenjdk_java_files.bp1028 "ojluni/src/main/java/java/util/concurrent/SynchronousQueue.java",
DEXPECTED_UPSTREAM1081 …/java/util/concurrent/SynchronousQueue.java,jdk21u/jdk-21.0.4-ga,src/java.base/share/classes/java/…
/libcore/api/
Dcurrent.txt16516 …public class SynchronousQueue<E> extends java.util.AbstractQueue<E> implements java.util.concurren…
16517 ctor public SynchronousQueue();
16518 ctor public SynchronousQueue(boolean);