ThreadPoolExecutor+Future 实现多线程等待功能

背景

ThreadPoolExcutor 是线程池的一种实现类，我们可以通过它创建一个线程池。

然后通过线程池提交多个FutureTask 进行任务的提交

最后通过 循环的方式 调用 Future.get() 实现线程的阻塞，等待FutureTask 全部执行完成

源码分析

针对上面的操作，在源码的层面是如何实现的呢？为什么future.get() 会阻塞线程呢？我们从jdk源码的角度去分析下

首先是任务的提交，使用的是submit

将我们的回调函数封装成 FutureTask,然后通过execute 去执行 task

封装成work ,然后调用run() 来执行

run 方法最后有解除阻塞的线程的方法

在finishCompletion() 中进行线程阻塞解除

Future.get方法，如果没执行完成则进行阻塞等待

最后再 finishCompletion() 中解除阻塞

总结

ThreadPoolExecutor+Future 的方式实现多线程的等待，最终使用的是LockSupport.park() 的方式阻塞未执行完的线程，Future 是一个顶级的父类接口，其实现类的实现方式都是大同小异的，希望这边文章能给你带来收获。