| /openjdk7/jdk/test/java/util/concurrent/BlockingQueue/ |
| H A D | PollMemoryLeak.java | 51 new SynchronousQueue(),
52 new SynchronousQueue(true),
|
| H A D | MultipleProducersSingleConsumerLoops.java | 101 oneRun(new SynchronousQueue<Integer>(), producers, iters);
104 oneRun(new SynchronousQueue<Integer>(true), producers, iters);
|
| H A D | ProducerConsumerLoops.java | 96 oneRun(new SynchronousQueue<Integer>(), pairs, iters);
101 oneRun(new SynchronousQueue<Integer>(true), pairs, iters);
|
| H A D | SingleProducerMultipleConsumerLoops.java | 82 oneRun(new SynchronousQueue<Integer>(), consumers, iters);
85 oneRun(new SynchronousQueue<Integer>(true), consumers, iters);
|
| H A D | CancelledProducerConsumerLoops.java | 127 oneRun(new SynchronousQueue<Integer>(), pairs, iters / 8);
|
| H A D | Interrupt.java | 118 testQueue(new SynchronousQueue<Object>());
|
| /openjdk7/jdk/test/java/util/concurrent/SynchronousQueue/ |
| H A D | Fairness.java | 69 testFairness(false, new SynchronousQueue<Integer>());
70 testFairness(false, new SynchronousQueue<Integer>(false));
71 testFairness(true, new SynchronousQueue<Integer>(true));
|
| /openjdk7/jdk/test/sun/management/jmxremote/ |
| H A D | LocalRMIServerSocketFactoryTest.java | 41 import java.util.concurrent.SynchronousQueue;
45 private static final SynchronousQueue<Exception> queue =
46 new SynchronousQueue<Exception>();
|
| /openjdk7/jdk/test/java/util/concurrent/ThreadPoolExecutor/ |
| H A D | SelfInterrupt.java | 37 new SynchronousQueue<Runnable>());
|
| H A D | TimeOutShrink.java | 47 new SynchronousQueue<Runnable>());
|
| /openjdk7/jdk/src/share/classes/sun/nio/ch/ |
| H A D | ThreadPool.java | 108 new SynchronousQueue<Runnable>(),
|
| /openjdk7/jdk/src/share/classes/java/util/concurrent/ |
| H A D | Executors.java | 181 new SynchronousQueue<Runnable>());
196 new SynchronousQueue<Runnable>(),
|
| H A D | SynchronousQueue.java | 56 * <tt>SynchronousQueue</tt> acts as an empty collection. This queue
82 public class SynchronousQueue<E> extends AbstractQueue<E> class in inherits:AbstractQueue,BlockingQueue,java.io.Serializable
429 * SynchronousQueue.{poll/offer} don't check interrupts
662 * happens in current SynchronousQueue, but could if
853 * Creates a <tt>SynchronousQueue</tt> with nonfair access policy.
855 public SynchronousQueue() { method in class:SynchronousQueue
860 * Creates a <tt>SynchronousQueue</tt> with the specified fairness policy.
865 public SynchronousQueue(boolean fair) { method in class:SynchronousQueue
961 * A <tt>SynchronousQueue</tt> has no internal capacity.
971 * A <tt>SynchronousQueue</t
[all...] |
| /openjdk7/jdk/test/java/util/Collections/ |
| H A D | EmptyIterator.java | 39 SynchronousQueue<Object>());
|
| /openjdk7/jdk/src/share/classes/sun/rmi/transport/tcp/ |
| H A D | TCPTransport.java | 60 import java.util.concurrent.SynchronousQueue;
110 new SynchronousQueue<Runnable>(),
|
| /openjdk7/jdk/make/java/java/ |
| H A D | FILES_java.gmk | 327 java/util/concurrent/SynchronousQueue.java \
|