| /openjdk7/jdk/test/java/util/concurrent/BlockingQueue/ |
| H A D | ProducerConsumerLoops.java | 91 oneRun(new ArrayBlockingQueue<Integer>(CAPACITY), pairs, iters);
92 oneRun(new LinkedBlockingQueue<Integer>(CAPACITY), pairs, iters);
93 oneRun(new LinkedBlockingDeque<Integer>(CAPACITY), pairs, iters);
94 oneRun(new LinkedTransferQueue<Integer>(), pairs, iters);
95 oneRun(new PriorityBlockingQueue<Integer>(), pairs, iters);
96 oneRun(new SynchronousQueue<Integer>(), pairs, iters);
101 oneRun(new SynchronousQueue<Integer>(true), pairs, iters);
102 oneRun(new ArrayBlockingQueue<Integer>(CAPACITY, true), pairs, iters);
166 static void oneRun(BlockingQueue<Integer> q, int npairs, int iters) throws Exception { method in class:ProducerConsumerLoops
|
| H A D | SingleProducerMultipleConsumerLoops.java | 77 oneRun(new ArrayBlockingQueue<Integer>(CAPACITY), consumers, iters);
78 oneRun(new LinkedBlockingQueue<Integer>(CAPACITY), consumers, iters);
79 oneRun(new LinkedBlockingDeque<Integer>(CAPACITY), consumers, iters);
80 oneRun(new LinkedTransferQueue<Integer>(), consumers, iters);
81 oneRun(new PriorityBlockingQueue<Integer>(), consumers, iters);
82 oneRun(new SynchronousQueue<Integer>(), consumers, iters);
85 oneRun(new SynchronousQueue<Integer>(true), consumers, iters);
86 oneRun(new ArrayBlockingQueue<Integer>(CAPACITY, true), consumers, iters);
153 static void oneRun(BlockingQueue<Integer> q, int nconsumers, int iters) throws Exception { method in class:SingleProducerMultipleConsumerLoops
|
| H A D | MultipleProducersSingleConsumerLoops.java | 91 oneRun(new ArrayBlockingQueue<Integer>(CAPACITY), producers, iters);
92 oneRun(new LinkedBlockingQueue<Integer>(CAPACITY), producers, iters);
93 oneRun(new LinkedBlockingDeque<Integer>(CAPACITY), producers, iters);
94 oneRun(new LinkedTransferQueue<Integer>(), producers, iters);
99 // oneRun(new PriorityBlockingQueue<Integer>(), producers, iters);
101 oneRun(new SynchronousQueue<Integer>(), producers, iters);
104 oneRun(new SynchronousQueue<Integer>(true), producers, iters);
105 oneRun(new ArrayBlockingQueue<Integer>(CAPACITY, true), producers, iters);
168 static void oneRun(BlockingQueue<Integer> q, int nproducers, int iters) throws Exception { method in class:MultipleProducersSingleConsumerLoops
|
| H A D | CancelledProducerConsumerLoops.java | 77 static void oneRun(BlockingQueue<Integer> q, int npairs, int iters) throws Exception { method in class:CancelledProducerConsumerLoops
124 oneRun(new ArrayBlockingQueue<Integer>(CAPACITY), pairs, iters);
125 oneRun(new LinkedBlockingQueue<Integer>(CAPACITY), pairs, iters);
126 oneRun(new LinkedBlockingDeque<Integer>(CAPACITY), pairs, iters);
127 oneRun(new SynchronousQueue<Integer>(), pairs, iters / 8);
130 oneRun(new PriorityBlockingQueue<Integer>(iters / 2 * pairs), pairs, iters / 4);
131 oneRun(new LinkedTransferQueue<Integer>(), pairs, iters);
|
| /openjdk7/jdk/test/java/util/concurrent/Exchanger/ |
| H A D | ExchangeLoops.java | 63 oneRun(2, 100000);
68 oneRun(i, iters);
121 static void oneRun(int nthreads, int iters) throws Exception { method in class:ExchangeLoops
|
| /openjdk7/jdk/test/java/util/concurrent/ConcurrentQueues/ |
| H A D | ConcurrentQueueLoops.java | 92 oneRun(1, items, q);
94 oneRun(3, items, q);
99 oneRun(i, items, q);
148 void oneRun(int n, int items, final Queue<Integer> q) throws Exception { method in class:ConcurrentQueueLoops
|