--- jsr166/src/test/loops/ConcurrentDequeLoops.java 2011/03/15 19:47:05 1.8 +++ jsr166/src/test/loops/ConcurrentDequeLoops.java 2015/08/10 03:13:33 1.12 @@ -18,7 +18,7 @@ public class ConcurrentDequeLoops { int maxStages = 8; int items = 1000000; - Class klass = null; + Class klass = null; if (args.length > 0) { try { klass = Class.forName(args[0]); @@ -43,8 +43,7 @@ public class ConcurrentDequeLoops { Thread.sleep(100); print = true; - int k = 1; - for (int i = 1; i <= maxStages;) { + for (int k = 1, i = 1; i <= maxStages;) { oneRun(klass, i, items); if (i == k) { k = i << 1; @@ -54,7 +53,7 @@ public class ConcurrentDequeLoops { i = k; } pool.shutdown(); - } + } static class Stage implements Callable { final Deque queue; @@ -117,7 +116,7 @@ public class ConcurrentDequeLoops { } } - static void oneRun(Class klass, int n, int items) throws Exception { + static void oneRun(Class klass, int n, int items) throws Exception { Deque q = (Deque) klass.newInstance(); LoopHelpers.BarrierTimer timer = new LoopHelpers.BarrierTimer(); CyclicBarrier barrier = new CyclicBarrier(n + 1, timer); @@ -141,6 +140,5 @@ public class ConcurrentDequeLoops { System.out.println(LoopHelpers.rightJustify(time / (items * n)) + " ns per item"); if (total == 0) // avoid overoptimization System.out.println("useless result: " + total); - } }