线程

一、概述

TioThreadUtils 是一个基于 java.util.concurrent.ExecutorService 封装的线程池工具类，用于在项目中统一管理和使用线程池资源。 它提供了：

• 全局唯一的固定大小线程池
• 统一的线程命名规则
• 简化的任务提交与执行方法
• 线程池的启动、停止与重启能力

适用于异步任务执行、并发处理、后台任务等场景。

---

二、线程池特性

1. 线程池类型

• FixedThreadPool（固定大小线程池）
• 线程数量计算规则：

int nThreads = max(16, CPU核心数 × 4)

确保在高并发场景下有足够的线程处理任务。

---

2. 线程命名规则

线程名称格式：

tio-utils-1
tio-utils-2
tio-utils-3
...

优点：

• 便于日志分析
• 方便排查线程问题
• 提升运维和调试效率

---

3. 生命周期管理

• 类加载时自动调用 start() 初始化线程池

• 支持手动：

  • 启动（start）
  • 停止（stop）
  • 重启（restart）

---

三、基本使用方法

1. 获取线程池实例

ExecutorService executorService = TioThreadUtils.getFixedThreadPool();

适用于需要直接操作 ExecutorService 的场景。

---

2. 提交 Runnable 任务（无返回值）

TioThreadUtils.submit(() -> {
  System.out.println("执行异步任务");
});

返回值：

Future<?> future

---

3. 提交 Runnable 任务（带返回结果）

Future<String> future = TioThreadUtils.submit(() -> {
  System.out.println("执行任务");
}, "success");

String result = future.get(); // 返回 "success"

---

4. 提交 Callable 任务（有返回值）

Future<Integer> future = TioThreadUtils.submit(() -> {
  // 业务逻辑
  return 100;
});

Integer result = future.get();

适用于需要计算结果或捕获异常的任务。

---

5. 直接执行任务（execute）

TioThreadUtils.execute(() -> {
  System.out.println("直接执行任务");
});

说明：

• 不返回 Future
• 适合“只执行、不关心结果”的任务

---

四、线程池控制方法

1. 启动线程池

TioThreadUtils.start();

说明：

• 默认在类加载时已自动调用
• 一般无需手动调用，除非曾调用过 stop()

---

2. 停止线程池

TioThreadUtils.stop();

行为：

• 调用 shutdownNow()
• 尝试中断所有正在执行的任务
• 将线程池引用置为 null

注意事项：

• 停止后不可再提交任务
• 再次使用前必须调用 start() 或 restart()

---

3. 重启线程池

TioThreadUtils.restart();

等价于：

TioThreadUtils.stop();
TioThreadUtils.start();

适用场景：

• 系统重载
• 配置热更新
• 异常恢复

---

五、使用建议与注意事项

1. 推荐使用场景

• IO 密集型任务
• 异步业务处理
• 后台任务执行
• 并发请求处理

---

2. 注意事项

• 不建议在任务中执行长时间阻塞操作（如无限等待）
• 提交任务前确保线程池未被 stop()
• 任务内部异常应自行捕获，避免影响线程复用
• 不适合对线程数量、队列策略有特殊要求的场景

---

六、示例：典型使用场景

public class OrderService {

  public void asyncCreateOrder() {
    TioThreadUtils.submit(() -> {
      // 创建订单
      // 发送消息
      // 写日志
    });
  }
}

---

七、总结

TioThreadUtils 提供了一种 简单、统一、可控 的线程池使用方式，适合在项目中作为默认的异步执行工具类。 通过合理使用，可以有效提升系统并发能力和代码可维护性。

如需更复杂的线程池策略（如队列控制、拒绝策略、动态扩容），可在此基础上进行扩展。