<dependency> <groupId>org.awaitility</groupId> <artifactId>awaitility</artifactId> <version>4.1.0</version> <scope>test</scope> </dependency> import org.awaitility.Awaitility; import java.util.concurrent.Executors; import java.util.concurrent.TimeUnit; public class MultiThreadTest { public void testMultiThread() { ExecutorService executorService = Executors.newFixedThreadPool(2); executorService.submit(() -> { Thread.sleep(2000); }); Awaitility.await().atMost(5, TimeUnit.SECONDS).until(() -> executorService.isTerminated() ); } }


上一篇:
下一篇:
切换中文