title: 新来个阿里 P7，仅花 2 小时，撸出一个多线程永动任务，看完直接跪了，真牛逼！ shortTitle: 新来个阿里 P7，仅花 2 小时，撸出一个多线程永动任务，看完直接跪了，真牛逼！ description: 今天教大家撸一个 Java 的多线程永动任务，这个示例的原型是公司自研的多线程异步任务项目，里面涉及的知识点非常多，特别适合有一定工作经验的同学学习，或者可以直接拿到项目中使用。 author: 楼仔 category:
- 微信公众号 head:
大家好，我是楼仔！
今天教大家撸一个 Java 的多线程永动任务，这个示例的原型是公司自研的多线程异步任务项目，我把里面涉及到多线程的代码抽离出来，然后进行一定的改造。
里面涉及的知识点非常多，特别适合有一定工作经验的同学学习，或者可以直接拿到项目中使用。
文章结构非常简单：
1. 功能说明
做这个多线程异步任务，主要是因为我们有很多永动的异步任务，什么是永动呢？就是任务跑起来后，需要一直跑下去。
比如消息 Push 任务，因为一直有消息过来，所以需要一直去消费 DB 中的未推送消息，就需要整一个 Push 的永动异步任务。
我们的需求其实不难，简单总结一下：
- 能同时执行多个永动的异步任务；
- 每个异步任务，支持开多个线程去消费这个任务的数据；
- 支持永动异步任务的优雅关闭，即关闭后，需要把所有的数据消费完毕后，再关闭。
完成上面的需求，需要注意几个点：
- 每个永动任务，可以开一个线程去执行；
- 每个子任务，因为需要支持并发，需要用线程池控制；
- 永动任务的关闭，需要通知子任务的并发线程，并支持永动任务和并发子任务的优雅关闭。
2. 多线程任务示例
2.1 线程池
对于子任务，需要支持并发，如果每个并发都开一个线程，用完就关闭，对资源消耗太大，所以引入线程池：
public class TaskProcessUtil {