private Callable<Boolean> joinThread(AsyncInvocation<Void> thread) {
    return () -> {
      try {
        thread.join(100L);
      } catch (InterruptedException e) {
        return false;
      }
      return !thread.isAlive();
    };
  }
This tests the data inconsistency during update on an index and querying the same UNLOCKED index.
geode-core/src/distributedTest/java/org/apache/geode/cache/query/dunit/QueryDataInconsistencyDUnitTest.java