如何优雅的创建线程

1.创建单线程

1. Thread
2. Runnable

2.单线程抽象类

抽象类 ServiceThread

实现类的编程模版类似

我们仅仅需要继承抽象类，并实现 getServiceName 和 run 方法即可。启动的时候，调用 start 方法 ， 关闭的时候调用 shutdown 方法

3.线程池原理

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

4.线程池封装

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

当服务端 Broker 接收到发送消息命令时，都会有单独的线程池 sendMessageExecutor 来处理这种命令请求。

BrokerFixedThreadPoolExecutor 构造函数包含六个核心参数：

1. 核心线程数和最大线程数相同 ，数量是：cpu核数和4比较后的最小值；
2. 空闲线程的回收的时间限制，默认1分钟；
3. 发送消息队列，有界队列，默认10000；
4. 线程工厂 ThreadFactoryImpl ，定义了线程名前缀：SendMessageThread_ 。

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

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

5.线程名很重要

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

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

日志文件

经常处理业务问题的同学，一定都经常与日志打交道。

• 查看 ERROR 日志，追溯到执行线程， 要是线程池隔离做的好，基本可以判断出哪种业务场景出了问题；
• 通过查看线程打印的日志，推断线程调度是否正常，比如有的定时任务线程打印了开始，没有打印结束，推论当前线程可能已经挂掉或者阻塞。

堆栈记录

jstack 是 java 虚拟机自带的一种堆栈跟踪工具 ，主要用来查看 Java 线程的调用堆栈，线程快照包含当前 java 虚拟机内每一条线程正在执行的方法堆栈的集合，可以用来分析线程问题。

jstack -l 进程pid
1

1. 当前 jvm 进程中的线程数量和线程分类是否在预期的范围内；
2. 系统接口超时或者定时任务停止的异常场景下 ，分析堆栈中是否有锁未释放，或者线程一直等待网络通讯响应；
3. 分析 jvm 进程中哪个线程占用的 CPU 最高。