Method run

test/ConcurrentHashMapTest.java:26–65

()

        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();
      }