在使用线程池,当多个线程异步执行的时候,我们往往不好判断是否线程池中所有的子线程都已经执行完毕,但有时候这种判断却很有用
1,监听线程池线程是否走完,使用showDown()方法,阻止线程池继续接收线程,然后whrle(true)循环判断是否线程池内线程全部执行完毕,但这个方法有个坏处,界面会处于阻塞状态,直到跳出循环
public static void main(String[] args) throws ExecutionException, InterruptedException {ExecutorService exec = Executors.newFixedThreadPool(4);for (int i = 0;i<10000;i++) {exec.execute(() -> System.out.println("aaaaaaaaaaaaaaaaaaaaaa"));}exec.shutdown();while(true){if(exec.isTerminated()){System.out.println("所有的子线程都结束了!");break;}Thread.sleep(1000);}}
2,通过shutdown将线程池不在接收新的线程,然后使用awaitTermination通过返回值true判断线程全部执行完成,这个方法更推荐使用,这个线程池任处于后台状态,主线程依然是空闲的,走完线程池任务后才会执行下一段代码
public static void main(String[] args) throws ExecutionException, InterruptedException {for (int i = 0;i<10000;i++) {exec.execute(() -> System.out.println("aaaaaaaaaaaaaaaaaaaaaa"));}exec.shutdown();
//请求关闭、发生超时或者当前线程中断,无论哪一个首先发生之后,都将导致阻塞,直到所有任务完成执行。boolean flag = exec.awaitTermination(1, TimeUnit.MINUTES);if(flag){System.out.println("结束了");}}