线程池的两个思考-德赢Vwin官网网

今天还是说一下线程池的两个思考。

池子

我们常用的线程池，

JDK的ThreadPoolExecutor.
CompletableFutures 默认使用了ForkJoinPool.commonPool()。

CompletableFuture.supplyAsync(()- >{ return "hello word";});

还有Tomcat中的线程池

org.apache.tomcat.util.threads.TaskQueue

org.apache.tomcat.util.threads.ThreadPoolExecutor

线程池维护多个线程，等待监督管理者分配可并发执行的任务。这种做法，一方面避免了处理任务时创建销毁线程开销的代价，另一方面避免了线程数量膨胀导致的过分调度问题，保证了对内核的充分利用。

JDK 线程池

public ThreadPoolExecutor(
    int corePoolSize, //核心线程数
    int maximumPoolSize,//最大线程数
    long keepAliveTime, //大于核心线程数量的线程存活时间，如果没有新任务就会关闭
    TimeUnit unit, // 时间单位
    BlockingQueue< Runnable > workQueue, //线程等待队列
    ThreadFactory threadFactory,//创建线程的工厂
    RejectedExecutionHandler handler//拒绝策略
) {

JDK线程池执行任务：

提交任务给线程池后，线程池会检查线程池中正在运行的线程数量，如果线程数量小于核心线程，则创建一个新的线程来处理任务。
如果线程池中线程数量达到和corePoolSize的大小，则将线程放入等待队列BlockingQueue中。
如果提交任务时连等待队列都已经满了的话，线程池会继续创建新的线程来处理任务，直到线程池数量达到maximumPoolSize。
如果线程数量达到了最大容量，则会执行拒绝策略。

这里需要注意直接使用LinkedBlockingQueue阻塞队列作为线程池会存在一个问题，当workcount > corePool时优先进入队列排队，当请求并发过多时会导致请求缓慢，队列太长可能会出现内存溢出（先排队再涨线程池）

Tomcat线程池

下面时Tomcat线程池的构造方法

public ThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueue< Runnable > workQueue, ThreadFactory threadFactory, RejectedExecutionHandler handler) {
    this.ctl = new AtomicInteger(ctlOf(-536870912, 0));
    this.mainLock = new ReentrantLock();
    this.workers = new HashSet();
    this.termination = this.mainLock.newCondition();
    this.submittedCount = new AtomicInteger(0);
    this.lastContextStoppedTime = new AtomicLong(0L);
    this.lastTimeThreadKilledItself = new AtomicLong(0L);
    this.threadRenewalDelay = 1000L;
    if (corePoolSize >= 0 && maximumPoolSize > 0 && maximumPoolSize >= corePoolSize && keepAliveTime >= 0L) {
        if (workQueue != null && threadFactory != null && handler != null) {
            this.corePoolSize = corePoolSize;
            this.maximumPoolSize = maximumPoolSize;
            this.workQueue = workQueue;
            this.keepAliveTime = unit.toNanos(keepAliveTime);
            this.threadFactory = threadFactory;
            this.handler = handler;
            this.prestartAllCoreThreads();
        } else {
            throw new NullPointerException();
        }
    } else {
        throw new IllegalArgumentException();
    }
}

Tomcat主要针对web接口请求，不能因为LinkedBlockingQueue的排队导致接口出现大量延迟和缓慢，从而使用了tomcat的TaskQueue，TaskQueue继承了JDK的LinkedBlockingQueue 并扩展了JDK线程池的功能。

主要有一下几点优化：

Tomcat的ThreadPoolExecutor使用的TaskQueue，是无界的LinkedBlockingQueue，但是通过taskQueue的offer方法覆盖了LinkedBlockingQueue的offer方法，修改了线程池增长规则，使得线程池能在任务较多的情况下增长线程池数量。（先涨线程池再排队。）
Tomcat的ThreadPoolExecutor改写了execute方法，当任务被reject时，捕获异常，会强制入队

public void execute(Runnable command, long timeout, TimeUnit unit) {
    this.submittedCount.incrementAndGet();

    try {
        this.executeInternal(command);
    } catch (RejectedExecutionException var9) {
        if (!(this.getQueue() instanceof TaskQueue)) {
            this.submittedCount.decrementAndGet();
            throw var9;
        }

        TaskQueue queue = (TaskQueue)this.getQueue();

        try {
            if (!queue.force(command, timeout, unit)) {
                this.submittedCount.decrementAndGet();
                throw new RejectedExecutionException(sm.getString("threadPoolExecutor.queueFull"));
            }
        } catch (InterruptedException var8) {
            this.submittedCount.decrementAndGet();
            throw new RejectedExecutionException(var8);
        }
    }

}

那个线程池适合

我们看看AI如何回复

了不起认为大多数情况下使用JDK的线程池就够用了，如果觉得线程数据处理不过来，需要多一点线程直接增加核心线程数量设置就可以了。针对资源比较紧张，对线程使用代价比较高时可以考虑。

tomcat对线程池做过优化，也必然是有一定的考量，对于线程资源的使用频率比较高的情况下可以使用。

声明：本文内容及配图由入驻作者撰写或者入驻合作网站授权转载。文章观点仅代表作者本人，不代表德赢Vwin官网网立场。文章及其配图仅供工程师学习之用，如有内容侵权或者其他违规问题，请联系本站处理。举报投诉

内核

内核

+关注

关注
3

文章
1372

浏览量
40273
接口

接口

+关注

关注
33

文章
8573

浏览量
151007
线程池

线程池

+关注

关注
0

文章
57

浏览量
6844
JDK

JDK

+关注

关注
0

文章
81

浏览量
16592
tomcat

tomcat

+关注

关注
0

文章
27

浏览量
4853

Java中的线程池包括哪些

java.util.concurrent 包来实现的，最主要的就是 ThreadPoolExecutor 类。 Executor: 代表线程池的接口，有一个 execute() 方法，给一个

发表于 10-11 15:33 •806次阅读

线程池创建的两种方法

1. 使用内置模块在使用多线程处理任务时也不是线程越多越好，由于在切换线程的时候，需要切换上下文环境，依然会造成cpu的大量开销。为解决这个问题，线程

发表于 03-16 16:15

两个线程和互斥锁如何形成死循环？

两个线程，两个互斥锁如何形成死锁？程序流程图如下：程序流程图如上图所示： t0时刻，主线程创建子线程，并初始化互斥锁mutex1、mut

发表于 01-02 16:47 •1485次阅读

两个线程，两个互斥锁如何形成死锁

两个线程，两个互斥锁如何形成死锁？程序流程图如下：程序流程图如上图所示： t0时刻，主线程创建子线程，并初始化互斥锁mutex1、mu

发表于 12-28 09:24 •2240次阅读

如何正确关闭线程池

前言本章分为两个议题如何正确关闭线程池 shutdown 和 shutdownNow 的区别项目环境jdk 1.8 github 地址：https://github.com

发表于 09-29 14:41 •9906次阅读

在Python中用于终止线程的两个选项

我经常被问到如何杀死一个后台线程，这个问题的答案让很多人不开心: 线程是杀不死的。在本文中，我将向您展示 Python 中用于终止线程的两个

发表于 11-17 10:02 •4664次阅读

python创建线程池的两种方法

在使用多线程处理任务时也不是线程越多越好，由于在切换线程的时候，需要切换上下文环境，依然会造成cpu的大量开销。为解决这个问题，线程池的概念

发表于 03-16 16:15 •5974次阅读

多线程之线程池

线程池通常用于服务器应用程序。每个传入请求都将分配给线程池中的一个线程，因此可以异步处理请求，而不会占用主

发表于 02-28 09:53 •786次阅读

如何用C++实现一个线程池呢？

C++线程池是一种多线程管理模型，把线程分成任务执行和线程调度两部分。

发表于 06-08 14:53 •1764次阅读

细数线程池的10个坑

JDK开发者提供了线程池的实现类，我们基于Executors组件，就可以快速创建一个线程池。

发表于 06-16 10:11 •722次阅读

Spring 的线程池应用

我们在日常开发中，经常跟多线程打交道，Spring 为我们提供了一个线程池方便我们开发，它就是 ThreadPoolTaskExecutor ，接下来我们就来聊聊 Spring 的

发表于 10-13 10:47 •619次阅读

线程池基本概念与原理

、17、20等的新特性，简化了多线程编程的实现。提高性能与资源利用率线程池主要解决两个问题：线程创建与销毁的开销以及

发表于 11-10 10:24 •527次阅读

线程池的基本概念

？呃呃，我这么问就很奇怪，因为线程池是什么我都没说，怎么会知道为什么会有线程池呢？所以我打算带大家去思考一

发表于 11-10 16:37 •518次阅读

线程池的创建方式有几种

线程池是一种用于管理和调度线程的技术，能够有效地提高系统的性能和资源利用率。它通过预先创建一组线程并维护一个工作队列，将任务提交给

发表于 12-04 16:52 •854次阅读

什么是动态线程池？动态线程池的简单实现思路

因此，动态可监控线程池一种针对以上痛点开发的线程池管理工具。主要可实现功能有：提供对 Spring 应用内线程

发表于 02-28 10:42 •634次阅读