Method runAtomicReferenceTest

test/AtomicTests.java:147–189

()

  }
  
  private static void runAtomicReferenceTest() {
    final AtomicReference<Integer> result = new AtomicReference<Integer>(0);
    final AtomicInteger threadDoneCount = new AtomicInteger(0);
    // only using an AtomicBoolean here so I don't need two variables to do the synchronize/wait/notify
    final AtomicBoolean threadsStart = new AtomicBoolean(false);
    
    Runnable operationRunnable = new Runnable() {
      @Override
      public void run() {
        for (int i = 0; i < iterationsPerThread; i++) {
          Integer current = result.get();
          while (! result.compareAndSet(current, current + 1)) {
            current = result.get();
          }
        }
      }
    };
    
    for (int i = 0; i < threadCount; i++) {
      new Thread(new DelayedRunnable(threadsStart, 
                                     operationRunnable, 
                                     threadDoneCount)).start();
    }
    
    synchronized (threadsStart) {
      threadsStart.set(true);
      
      threadsStart.notifyAll();
    }
    
    try {
      blockTillThreadsDone(threadDoneCount);
    } catch (InterruptedException e) {
      // let thread exit
      return;
    }
    
    long expectedResult = threadCount * iterationsPerThread;
    Integer resultValue = result.get();
    if (resultValue != expectedResult) {
      throw new IllegalStateException(resultValue + " != " + expectedResult);
    }
  }
  
  private static class DelayedRunnable implements Runnable {
    private final AtomicBoolean threadsStart;