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.java48 import java.util.concurrent.SynchronousQueue;
56 return new SynchronousQueue(true); in emptyCollection()
62 return new SynchronousQueue(false); in emptyCollection()
82 final SynchronousQueue q = new SynchronousQueue(fair); in testEmptyFull()
95 SynchronousQueue q = new SynchronousQueue(fair); in testOffer()
105 SynchronousQueue q = new SynchronousQueue(fair); in testAdd()
119 SynchronousQueue q = new SynchronousQueue(fair); in testAddAll_self()
132 SynchronousQueue q = new SynchronousQueue(fair); in testAddAll_ISE()
149 final SynchronousQueue q = new SynchronousQueue(fair); in testBlockingPut()
181 final SynchronousQueue q = new SynchronousQueue(fair); in testPutWithTake()
[all …]
DRecursiveActionTest.java45 import java.util.concurrent.SynchronousQueue;
358 final SynchronousQueue<FibAction[]> sq = in testJoinIgnoresInterruptsOutsideForkJoinPool()
359 new SynchronousQueue<FibAction[]>(); in testJoinIgnoresInterruptsOutsideForkJoinPool()
DJSR166TestCase.java115 import java.util.concurrent.SynchronousQueue;
2195 new SynchronousQueue<Runnable>());
DThreadPoolExecutorTest.java56 import java.util.concurrent.SynchronousQueue;
78 super(1, 1, LONG_DELAY_MS, MILLISECONDS, new SynchronousQueue<Runnable>()); in ExtendedTPE()
DThreadPoolExecutorSubclassTest.java55 import java.util.concurrent.SynchronousQueue;
225 super(1, 1, LONG_DELAY_MS, MILLISECONDS, new SynchronousQueue<Runnable>()); in CustomTPE()
/libcore/ojluni/src/test/java/util/Collections/
DEmptyIterator.java40 import java.util.concurrent.SynchronousQueue;
56 testEmptyCollection(new SynchronousQueue<Object>()); in test()
/libcore/ojluni/src/main/java/java/util/concurrent/
DExecutors.java225 new SynchronousQueue<Runnable>()); in newCachedThreadPool()
241 new SynchronousQueue<Runnable>(), in newCachedThreadPool()
DSynchronousQueue.java90 public class SynchronousQueue<E> extends AbstractQueue<E> class
816 public SynchronousQueue() { in SynchronousQueue() method in SynchronousQueue
826 public SynchronousQueue(boolean fair) { in SynchronousQueue() method in SynchronousQueue
/libcore/
Dopenjdk_java_files.bp1024 "ojluni/src/main/java/java/util/concurrent/SynchronousQueue.java",
DEXPECTED_UPSTREAM1075 …/java/util/concurrent/SynchronousQueue.java,jdk17u/jdk-17.0.6-ga,src/java.base/share/classes/java/…
/libcore/api/
Dcurrent.txt16336 …public class SynchronousQueue<E> extends java.util.AbstractQueue<E> implements java.util.concurren…
16337 ctor public SynchronousQueue();
16338 ctor public SynchronousQueue(boolean);