equal
deleted
inserted
replaced
154 public void testAccumulateAndGetMT() { |
154 public void testAccumulateAndGetMT() { |
155 final DoubleAccumulator acc |
155 final DoubleAccumulator acc |
156 = new DoubleAccumulator((x, y) -> x + y, 0.0); |
156 = new DoubleAccumulator((x, y) -> x + y, 0.0); |
157 final int nThreads = ThreadLocalRandom.current().nextInt(1, 5); |
157 final int nThreads = ThreadLocalRandom.current().nextInt(1, 5); |
158 final Phaser phaser = new Phaser(nThreads + 1); |
158 final Phaser phaser = new Phaser(nThreads + 1); |
159 final int incs = 1_000_000; |
159 final int incs = expensiveTests ? 1_000_000 : 100_000; |
160 final double total = nThreads * incs/2.0 * (incs - 1); // Gauss |
160 final double total = nThreads * incs/2.0 * (incs - 1); // Gauss |
161 final Runnable task = () -> { |
161 final Runnable task = () -> { |
162 phaser.arriveAndAwaitAdvance(); |
162 phaser.arriveAndAwaitAdvance(); |
163 for (int i = 0; i < incs; i++) { |
163 for (int i = 0; i < incs; i++) { |
164 acc.accumulate((double) i); |
164 acc.accumulate((double) i); |