Method main

test/ConcurrentHashMapTest.java:16–106

(String[] args)

  }

  public static void main(String[] args) throws Throwable {
    final ConcurrentMap<Integer, Object> map = new ConcurrentHashMap();
    final int[] counter = new int[1];
    final int[] step = new int[1];
    final Throwable[] exception = new Throwable[1];

    synchronized (map) {
      for (int i = 0; i < ThreadCount; ++i) {
        final int index = i;
        new Thread() {
          public void run() {
            try {
              synchronized (map) {
                ++ counter[0];
                map.notifyAll();
                while (exception[0] == null && step[0] == 0) {
                  map.wait();
                }
              }

              for (int i = 0; i < IterationCount; ++i) {
                populateCommon(map);
                populate(map, index * Range);
              }

              synchronized (map) {
                -- counter[0];
                map.notifyAll();
                while (exception[0] == null && step[0] == 1) {
                  map.wait();
                }
              }

              for (int i = 0; i < IterationCount; ++i) {
                populate(map, index * Range);
                depopulate(map, index * Range);
              }

              synchronized (map) {
                ++ counter[0];
                map.notifyAll();
              }
            } catch (Throwable e) {
              synchronized (map) {
                exception[0] = e;
                map.notifyAll();
              }
              e.printStackTrace();
            }
          }
        }.start();
      }

      try {
        while (exception[0] == null && counter[0] < ThreadCount) {
          map.wait();
        }