关于java:读完-RocketMQ-源码我学会了如何优雅的创建线程

RocketMQ 是一款开源的分布式音讯零碎，基于高可用分布式集群技术，提供低延时、高牢靠的音讯公布与订阅服务。

这篇文章，笔者整顿了 RocketMQ 源码中创立线程的几点技巧，心愿大家读完之后，可能有所播种。

首先咱们先复习下罕用的创立单线程的两种形式：

▍一、实现 Runnable 接口

图中，MyRunnable 类实现了 Runnable 接口的 run 办法，run 办法中定义具体的工作代码或解决逻辑，而 Runnable 对象是作为线程构造函数的参数。

▍二、继承 Thread 类

线程实现类间接继承 Thread，实质上也是实现 Runnable 接口的 run 办法。

创立单线程的两种形式都很简略，但每次创立线程代码显得有点冗余，于是 RocketMQ 里实现了一个抽象类 ServiceThread。

咱们能够看到抽象类中蕴含了如下外围办法：

下图展现了 RocketMQ 泛滥的单线程实现类。

实现类的编程模版相似：

咱们仅仅须要继承抽象类，并实现 getServiceName 和 run 办法即可。启动的时候，调用 start 办法，敞开的时候调用 shutdown 办法。

线程池是一种基于池化思维治理线程的工具，线程池保护着多个线程，期待着监督管理者调配可并发执行的工作。这防止了在解决短时间工作时创立与销毁线程的代价。线程池不仅可能保障内核的充分利用，还能避免过分调度。

JDK 中提供的 ThreadPoolExecutor 类，是咱们最常应用的线程池类。

参数名	作用
corePoolSize	队列没满时，线程最大并发数
maximumPoolSizes	队列满后线程可能达到的最大并发数
keepAliveTime	闲暇线程过多久被回收的工夫限度
unit	keepAliveTime 的工夫单位
workQueue	阻塞的队列类型
threadPoolFactory	扭转线程的名称、线程组、优先级、守护过程状态
RejectedExecutionHandler	超出 maximumPoolSizes + workQueue 时，工作会交给 RejectedExecutionHandler 来解决

工作的调度通过执行 execute 办法实现，办法的外围流程如下：

如果 workerCount < corePoolSize，创立并启动一个线程来执行新提交的工作。
如果 workerCount >= corePoolSize，且线程池内的阻塞队列未满，则将工作增加到该阻塞队列中。
如果 workerCount >= corePoolSize && workerCount < maximumPoolSize，且线程池内的阻塞队列已满，则创立并启动一个线程来执行新提交的工作。
如果 workerCount >= maximumPoolSize，并且线程池内的阻塞队列已满, 则依据回绝策略来解决该工作, 默认的解决形式是间接抛异样。

在 RocketMQ 里，网络申请都会携带命令编码，每种命令映射对应的处理器，而处理器又会注册对应的线程池。

当服务端 Broker 接管到发送音讯命令时，都会有独自的线程池 sendMessageExecutor 来解决这种命令申请。

基于 ThreadPoolExecutor 做了一个简略的封装，BrokerFixedThreadPoolExecutor 构造函数蕴含六个外围参数：

RocketMQ 实现了一个简略的线程工厂：ThreadFactoryImpl，线程工厂能够定义线程名称，以及是否是守护线程。

开源我的项目 Cobar，Xmemcached，Metamorphosis 中都有相似线程工厂的实现。

线程名很重要，线程名很重要，线程名很重要，重要的事件说三遍。

咱们看到 RocketMQ 中，无论是单线程抽象类还是多线程的封装都会配置线程名，因为通过线程名，非常容易定位问题，从而大大晋升解决问题的效率。

定位的媒介常见有两种：日志文件 和堆栈记录。

▍一、日志文件

常常解决业务问题的同学，肯定都常常与日志打交道。

▍二、堆栈记录

jstack 是 java 虚拟机自带的一种堆栈跟踪工具，次要用来查看 Java 线程的调用堆栈，线程快照蕴含以后 java 虚拟机内每一条线程正在执行的办法堆栈的汇合，能够用来剖析线程问题。

jstack -l 过程 pid

笔者查看线程堆栈，个别关注如下几点：

本文是 RocketMQ 系列文章的开篇，和敌人们简略聊聊 RocketMQ 源码里创立线程的技巧。

RocketMQ 的多线程编程技巧很多，比方线程通信，并发管制，线程模型等等，后续的文章会一一为大家展示。

1 创立单线程