void (@NotNull CountDownLatch latch) { try { if (!latch.await(5, TimeUnit.SECONDS)) { Assert.fail("timeout:\n" + ThreadDumper.dumpThreadsToString()); } } catch (InterruptedException e) { throw new RuntimeException(e); } }