读完 RocketMQ 源码，我学会了如何优雅的创建线程

RocketMQ 是一款开源的分布式消息系统，基于高可用分布式集群技术，提供低延时、高可靠的消息发布与订阅服务。

这篇文章，笔者整理了 RocketMQ 源码中创建线程的几点技巧，希望大家读完之后，能够有所收获。

1 创建单线程

首先我们先温习下常用的创建单线程的两种方式：

• 实现 Runnable 接口
• 继承 Thread 类

▍一、实现 Runnable 接口

 

 

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

▍二、 继承 Thread 类

 

 

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

2 单线程抽象类

创建单线程的两种方式都很简单，但每次创建线程代码显得有点冗余ÿ