Hutool Hutool
(opens new window)
🏡首页
📖指南
🎢最佳实践
💖支持
💡javaDoc (opens new window)
⏳更新记录 (opens new window)
  • 🍎gitee (opens new window)
  • 🍏github (opens new window)
(opens new window)
🏡首页
📖指南
🎢最佳实践
💖支持
💡javaDoc (opens new window)
⏳更新记录 (opens new window)
  • 🍎gitee (opens new window)
  • 🍏github (opens new window)
  • 快速入门

  • 核心(hutool-core)

    • AI(Hutool-ai)

    • 注解(annotation)

    • 数组(array)

    • JavaBean(bean)

    • 缓存(cache)

    • 类加载器(classloader)

    • 编码解码(codec)

    • 集合(collection)

    • 比较器(comparator)

    • 压缩(compress)

    • 类型转换(convert)

    • 数据(data)

    • 日期时间(date)

    • 异常(exception)

    • 函数(func)

    • IO流(io)

    • 语言特性(lang)

    • Map(map)

    • 数字数学(math)

    • 网络(net)

    • 对象池(pool)

    • 反射(reflect)

    • 正则(regex)

    • 服务提供(spi)

    • 聚合操作(stream)

    • 字符串文本(text)

    • 并发和线程(thread)

      • 简介
      • 线程工具-ThreadUtil
      • 异步工具类-AsyncUtil
      • 自定义线程池-ExecutorBuilder
        • 由来
          • 概念
          • 线程池对待线程的策略
          • workQueue线程池策略
        • 使用
      • 高并发测试-ConcurrencyTester
    • 树结构(tree)

    • 工具集合(util)

    • XML操作(xml)

  • 定时任务(hutool-cron)

  • 加密(hutool-crypto)

  • 数据库(hutool-db)

  • 扩展(hutool-extra)

  • HTTP(hutool-http)

  • 日志(hutool-log)

  • 配置文件(hutool-setting)

  • JSON(hutool-json)

  • Office办公(hutool-poi)

  • 套接字(hutool-socket)

  • GUI(hutool-swing)

  • 指南
  • 核心(hutool-core)
  • 并发和线程(thread)
Hutool
2026-01-03
目录

自定义线程池-ExecutorBuilder

# 由来

在JDK中,提供了Executors用于创建自定义的线程池对象ExecutorService,但是考虑到线程池中存在众多概念,这些概念通过不同的搭配实现灵活的线程管理策略,单独使用Executors无法满足需求,所以构建了ExecutorBuilder。

# 概念

  • corePoolSize 初始池大小
  • maxPoolSize 最大池大小(允许同时执行的最大线程数)
  • workQueue 队列,用于存储未执行的任务
  • handler 当线程阻塞(block)时的异常处理器,所谓线程阻塞即线程池和等待队列已满,无法处理线程时采取的策略

# 线程池对待线程的策略

  1. 如果池中任务数 < corePoolSize -> 放入立即执行
  2. 如果池中任务数 > corePoolSize -> 放入队列等待
  3. 队列满 -> 新建线程立即执行
  4. 执行中的线程 > maxPoolSize -> 触发handler(RejectedExecutionHandler)异常

# workQueue线程池策略

  • SynchronousQueue 它将任务直接提交给线程而不保持它们。当运行线程小于maxPoolSize时会创建新线程,否则触发异常策略
  • LinkedBlockingQueue 默认无界队列,当运行线程大于corePoolSize时始终放入此队列,此时maxPoolSize无效。当构造LinkedBlockingQueue对象时传入参数,变为有界队列,队列满时,运行线程小于maxPoolSize时会创建新线程,否则触发异常策略
  • ArrayBlockingQueue 有界队列,相对无界队列有利于控制队列大小,队列满时,运行线程小于maxPoolSize时会创建新线程,否则触发异常策略

# 使用

  1. 默认线程池

策略如下:

  • 初始线程数为corePoolSize指定的大小
  • 没有最大线程数限制
  • 默认使用LinkedBlockingQueue,默认队列大小为1024(最大等待数1024)
  • 当运行线程大于corePoolSize放入队列,队列满后抛出异常
ExecutorService executor = ExecutorBuilder builder = ExecutorBuilder.create()..build();
  1. 单线程线程池
  • 初始线程数为 1
  • 最大线程数为 1
  • 默认使用LinkedBlockingQueue,默认队列大小为1024
  • 同时只允许一个线程工作,剩余放入队列等待,等待数超过1024报错
ExecutorService executor = ExecutorBuilder.create()//
    .setCorePoolSize(1)//
    .setMaxPoolSize(1)//
    .setKeepAliveTime(0)//
    .build();
  1. 更多选项的线程池
  • 初始5个线程
  • 最大10个线程
  • 有界等待队列,最大等待数是100
ExecutorService executor = ExecutorBuilder.create()
    .setCorePoolSize(5)
    .setMaxPoolSize(10)
    .setWorkQueue(new LinkedBlockingQueue<>(100))
    .build();
  1. 特殊策略的线程池
  • 初始5个线程
  • 最大10个线程
  • 它将任务直接提交给线程而不保持它们。当运行线程小于maxPoolSize时会创建新线程,否则触发异常策略
ExecutorService executor = ExecutorBuilder.create()
    .setCorePoolSize(5)
    .setMaxPoolSize(10)
    .useSynchronousQueue()
    .build();
异步工具类-AsyncUtil
高并发测试-ConcurrencyTester

← 异步工具类-AsyncUtil 高并发测试-ConcurrencyTester→

Theme by Vdoing | Copyright © 2025-2026 Hutool | Apache-2.0
  • 跟随系统
  • 浅色模式
  • 深色模式
  • 阅读模式