--- jsr166/src/test/jtreg/util/Collections/RacingCollections.java 2010/09/27 19:15:15 1.4 +++ jsr166/src/test/jtreg/util/Collections/RacingCollections.java 2015/02/18 21:02:11 1.6 @@ -62,14 +62,16 @@ public class RacingCollections { this.start(); } - @SuppressWarnings("unchecked") void clear(Object o) { + @SuppressWarnings("unchecked") + void clear(Object o) { if (o instanceof Collection) ((Collection)o).clear(); else ((Map)o).clear(); } - @SuppressWarnings("unchecked") void realRun() { + @SuppressWarnings("unchecked") + void realRun() { // Mutate elLoco wildly forever, checking occasionally for "done" clear(elLoco); if (elLoco instanceof List) { @@ -156,7 +158,7 @@ public class RacingCollections { quittingTime = System.nanoTime() + workTimeMillis * 1024 * 1024; } boolean keepGoing() { - return (i++ % 128 != 0) || (System.nanoTime() < quittingTime); + return (i++ % 128 != 0) || (System.nanoTime() - quittingTime < 0); } } @@ -233,6 +235,7 @@ public class RacingCollections { private static List> newConcurrentQueues() { List> list = new ArrayList>(newConcurrentDeques()); + list.add(new ArrayBlockingQueue(10)); list.add(new LinkedBlockingQueue(10)); list.add(new LinkedTransferQueue()); list.add(new ConcurrentLinkedQueue());