@Override
    public void execute() throws ExecutionException, InterruptedException {
      while (callablesStarting.get() > 0) {
      }

      start.countDown();
      for (Future future : futures) {
        future.get();
      }
      futures.clear();
    }
Simple runner that just runs the test in a loop
geode-concurrency-test/src/main/java/org/apache/geode/test/concurrency/loop/LoopRunner.java