< prev index next >
test/jdk/java/util/concurrent/tck/LongAccumulatorTest.java
Print this page
8225490: Miscellaneous changes imported from jsr166 CVS 2019-09
Reviewed-by: martin, alanb
*** 148,158 ****
public void testAccumulateAndGetMT() {
final LongAccumulator acc
= new LongAccumulator((x, y) -> x + y, 0L);
final int nThreads = ThreadLocalRandom.current().nextInt(1, 5);
final Phaser phaser = new Phaser(nThreads + 1);
! final int incs = 1_000_000;
final long total = nThreads * incs/2L * (incs - 1); // Gauss
final Runnable task = () -> {
phaser.arriveAndAwaitAdvance();
for (int i = 0; i < incs; i++) {
acc.accumulate((long) i);
--- 148,158 ----
public void testAccumulateAndGetMT() {
final LongAccumulator acc
= new LongAccumulator((x, y) -> x + y, 0L);
final int nThreads = ThreadLocalRandom.current().nextInt(1, 5);
final Phaser phaser = new Phaser(nThreads + 1);
! final int incs = expensiveTests ? 1_000_000 : 100_000;
final long total = nThreads * incs/2L * (incs - 1); // Gauss
final Runnable task = () -> {
phaser.arriveAndAwaitAdvance();
for (int i = 0; i < incs; i++) {
acc.accumulate((long) i);
< prev index next >