@Override
  public void close() {
    wanCopyRegionFunctionExecutionPool.shutdownNow();
    try {
      if (!wanCopyRegionFunctionExecutionPool.awaitTermination(5, TimeUnit.SECONDS)) {
        wanCopyRegionFunctionExecutionPool.shutdownNow();
      }
    } catch (InterruptedException ie) {
      wanCopyRegionFunctionExecutionPool.shutdownNow();
      Thread.currentThread().interrupt();
    }
  }
Contains the ongoing executions of WanCopyRegionFunction
geode-wan/src/main/java/org/apache/geode/cache/wan/internal/WanCopyRegionFunctionService.java