// The non-atomic summation doesn't always yield the correct result
// as we are quite certainly violating the memory model with these
// "unprotected" additions.

sclass CompactQTest {
  long acc;
  new AtomicLong atomicAccumulator;
  int n = 100000;
  
  new CompactQ q;
  int qSizeAtEnd;
  long time;
  Scorer scorer;
  
  begin.

  long expectedResult = longMul(n, n+1)/2;
  printVars(+n, +expectedResult);
  S name = "Queue " + n;
  time name {
    for (r : inclusiveCountIterator(1, n, i -> r {
      acc += i; 
      add(atomicAccumulator, i);
    }))
      q.add(r);
    qSizeAtEnd = q.size();
    q.waitUntilDone();
    assertEqualsVerbose(scorer, "Non-Atomic", expectedResult, acc);
    assertEqualsVerbose(scorer, "Atomic", expectedResult, atomicAccumulator!);
  }
  time = lastTiming();
  print(n2(acc) + " // " + n2(qSizeAtEnd));
}