OpenJDK / amber / amber
changeset 4530:cff832a17f52
6908348: java/util/concurrent/BlockingQueue/CancelledProducerConsumerLoops.java get OOME for unbounded queues
Reviewed-by: martin, dholmes
| author | dl |
|---|---|
| date | Wed, 23 Dec 2009 15:57:14 -0800 |
| parents | 9403e6487c07 |
| children | 3a9206343ab2 |
| files | jdk/test/java/util/concurrent/BlockingQueue/CancelledProducerConsumerLoops.java |
| diffstat | 1 files changed, 4 insertions(+), 4 deletions(-) [+] |
line wrap: on
line diff
--- a/jdk/test/java/util/concurrent/BlockingQueue/CancelledProducerConsumerLoops.java Wed Dec 23 17:17:16 2009 +0000 +++ b/jdk/test/java/util/concurrent/BlockingQueue/CancelledProducerConsumerLoops.java Wed Dec 23 15:57:14 2009 -0800 @@ -146,13 +146,13 @@ oneRun(new ArrayBlockingQueue<Integer>(CAPACITY), pairs, iters); oneRun(new LinkedBlockingQueue<Integer>(CAPACITY), pairs, iters); oneRun(new LinkedBlockingDeque<Integer>(CAPACITY), pairs, iters); + oneRun(new SynchronousQueue<Integer>(), pairs, iters / 8); + + /* TODO: unbounded queue implementations are prone to OOME + oneRun(new PriorityBlockingQueue<Integer>(iters / 2 * pairs), pairs, iters / 4); oneRun(new LinkedTransferQueue<Integer>(), pairs, iters); oneRun(new LTQasSQ<Integer>(), pairs, iters); oneRun(new HalfSyncLTQ<Integer>(), pairs, iters); - oneRun(new SynchronousQueue<Integer>(), pairs, iters / 8); - - /* PriorityBlockingQueue is unbounded - oneRun(new PriorityBlockingQueue<Integer>(iters / 2 * pairs), pairs, iters / 4); */ }