private void awaitAllAsyncInvocations() throws ExecutionException, InterruptedException {
    for (AsyncInvocation<Void> async : asyncInvocations) {
      async.await();
    }
    asyncInvocations.clear();
  }
This tests persistence conflicts btw members of partition region
geode-core/src/distributedTest/java/org/apache/geode/internal/cache/PartitionedRegionCreationDUnitTest.java