@Test
  public void hangsOnWindows() throws Exception {
    // arrange
    givenRunningProcessWithStreamReaders(ProcessSleeps.class);

    // act
    Future<Boolean> future = executorServiceRule.submit(() -> {
      process.getOutputStream().close();
      process.getErrorStream().close();
      process.getInputStream().close();
      return true;
    });

    // assert
    assertThatThrownBy(() -> future.get(HANG_TIMEOUT_SECONDS, SECONDS))
        .isInstanceOf(TimeoutException.class);
  }
Timeout to confirm hang on Windows
geode-core/src/integrationTest/java/org/apache/geode/internal/process/BlockingProcessStreamReaderWindowsTest.java