Spring(19) ThreadPoolTaskExecutor 线程池的使用

这篇具有很好参考价值的文章主要介绍了Spring(19) ThreadPoolTaskExecutor 线程池的使用。希望对大家有所帮助。如果存在错误或未考虑完全的地方,请大家不吝赐教,您也可以点击"举报违法"按钮提交疑问。

一、线程池简介

1.1 为什么使用线程池

  • 降低系统资源消耗: 通过重用已存在的线程,降低线程创建和销毁造成的消耗;
  • 提高系统响应速度: 当有任务到达时,通过复用已存在的线程,无需等待新线程的创建便能立即执行;
  • 方便线程并发数的管控: 因为线程若是无限制的创建,可能会导致内存占用过多而产生 OOM,并且会造成 CPU 过度切换(CPU 切换线程是有时间成本的,需要保持当前执行线程的现场,并恢复要执行线程的现场);
  • 提供更强大的功能: 延时定时线程池。

1.2 线程池为什么需要使用队列

因为线程若是无限制的创建,可能会导致 内存 占用过多而产生 OOM,并且会造成 CPU 过度切换。

创建线程池的消耗较高,或者线程池创建线程需要获取 mainlock 这个全局锁,影响并发效率,阻塞队列可以很好的缓冲。

1.3 线程池为什么要使用阻塞队列而不是用非阻塞队列

阻塞队列 可以保证任务队列中没有任务是阻塞获取任务的线程,使得线程进入 wait 状态,释放 CPU 资源,当队列中有任务时才唤醒对应线程从队列中取出消息进行执行。

使得线程不至于一直占用 CPU 资源。(线程执行完任务后通过循环再次从任务队列中取出任务进行执行,代码片段如:while (task != null || (task = getTask()) != null) {})。

不用阻塞队列也是可以的,不过实现起来比较麻烦而已,有好用的为啥不用呢?

1.4 如何配置线程池

  • CPU密集型任务:

    尽量使用较小的线程池,一般为 CPU 核心数 +1。因为 CPU密集型任务使得 CPU 使用率很高,若开很多的线程数,会造成 CPU 过度切换。

  • IO密集型任务:

    可以使用较大的线程池,一般为 2*CPU 核心数。IO密集型任务 CPU 使用率并不高,因此可以让 CPU 在等待 IO 的时候有其他线程去处理别的任务,充分利用 CPU 时间。

  • 混合型任务:

    可以将任务分为 IO密集型和 CPU密集型任务,然后分别用不同的线程池去处理。只要分完之后两个任务的执行时间相差不大,那么就会比串行执行来的高效。

    因为如果划分之后两个任务执行时间有数据级别的差距,那么拆分没有意义。因为先执行完的任务就要等候执行完的任务,最终的时间仍然取决于后执行完的任务,而且还要加上任务拆分与合并的开销,得不偿失。

1.5 execute() 和 submit() 方法

  • execute():执行一个任务,没有返回值。
  • submit():提交一个任务,有返回值。

submit() 方法的使用如下:

  • submit(Callable<T> task): 能够获取到它的返回值,通过 feature.get() 获取(阻塞直到任务执行完)。一般使用 FutureTask + Callable 配合使用。
  • submit(Runnable task, T result):能通过传入的载体 result 间接获得线程的返回值。
  • submit(Runnable task):则是没有返回值的,就算获取它的返回值也是 null

future.get() 方法会使获取结果的线程进入 阻塞状态,直到线程执行完成之后,唤醒获取结果的线程,然后返回结果。


二、ThreadPoolTaskExecutor 线程池简介

2.1 简介

  • ThreadPoolTaskExecutor 是 Spring Framework 提供的一个线程池执行器,它基于 java.util.concurrent 包中的 ThreadPoolExecutor 实现,并提供了更方便的 Spring 配置和生命周期管理。

在 Spring 应用程序中,你可以通过配置一个 ThreadPoolTaskExecutor 来创建并管理一个自定义的线程池。这个线程池可以根据你的需求设置 核心线程数最大线程数队列容量线程存活时间 以及 拒绝策略 等属性。

2.2 核心参数配置

  • corePoolSize最小线程数,默认为 1
  • maxPoolSize最大线程数,默认为 Integer.MAX_VALUE
  • keepAliveSeconds(maxPoolSize-corePoolSzie)部分线程空闲最大存活时间,默认存活时间是 60s
  • queueCapacity阻塞队列的大小,默认为 Integer.MAX_VALUE,默认使用 LinkedBlockingQueue
  • allowCoreThreadTimeOut是否允许核心线程过期,设置为 true 的话,keepAliveSeconds 参数设置的有效时间对 corePoolSize 线程也有效,默认是 false
  • threadNamePrefix线程名称前缀,为 ThreadPoolTaskExecutor 的增强功能,默认为“类名-”。
  • threadFactory设置创建线程的工厂,可以通过线程工厂给每个创建出来的线程设置更有意义的名字。使用开源框架 guava 提供的 ThreadFactoryBuilder 可以快速给线程池里的线程设置有意义的名字。
  • rejectedExecutionHandler拒绝策略,当队列 workQueue 和线程池 maxPoolSize 都满了,说明线程池处于饱和状态,那么必须采取一种策略处理提交的新任务。这个策略默认情况下是 AbortPolicy,表示无法处理新任务时抛出异常。

2.3 ThreadPoolTaskExecutor 内部执行流程

Spring(19) ThreadPoolTaskExecutor 线程池的使用,Spring,spring,java,后端

我们通过 execute(Runnable) 方法或者 submit(Runnable) 方法将 Runnable 任务添加到线程池时:

  • 如果线程池中的数量小于 corePoolSize,即使线程池中的线程都处于空闲状态,也要 创建新的线程来处理被添加的任务
  • 如果线程池中的数量等于 corePoolSize,但是缓冲队列 workQueue 未满,那么 任务被放入缓冲队列
  • 如果线程池中的数量大于 corePoolSize,缓冲队列 workQueue 满了,并且:
    • 线程池中的数量小于 maxPoolSize,则 创建新的线程来处理被添加的任务
    • 线程池中的数量等于 maxPoolSize,则 通过 handler 所指定的拒绝策略来处理被添加的任务

也就是说,处理任务的优先级为:

核心线程corePoolSize > 任务队列workQueue > 最大线程maxPoolSize > 拒绝策略handler


三、ThreadPoolTaskExecutor 的代码示例

3.1 配置线程池示例

ThreadPoolConfig.java

import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;

/**
 * <p> @Title ThreadPoolConfig
 * <p> @Description 线程池配置
 *
 * @author ACGkaka
 * @date 2024/01/18 21:08
 */
@Configuration
public class ThreadPoolConfig {

    /** 最佳线程数:操作系统线程数+2 */
    private static final int CORE_POOL_SIZE = Runtime.getRuntime().availableProcessors() + 2;
    /** 最大线程数 */
    private static final int MAX_POOL_SIZE = CORE_POOL_SIZE * 2;
    /** 队列长度 */
    private static final int QUEUE_CAPACITY = 10000;

    /**
     * 发送短信线程池
     */
    @Bean
    public ThreadPoolTaskExecutor sendSMSThreadPool() {
        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
        executor.setCorePoolSize(CORE_POOL_SIZE);
        executor.setMaxPoolSize(MAX_POOL_SIZE);
        executor.setQueueCapacity(QUEUE_CAPACITY);
        executor.setThreadNamePrefix("SendSMS-");
        // 等待任务执行完毕后再关闭线程池
        executor.setWaitForTasksToCompleteOnShutdown(true);
        executor.initialize();
        return executor;
    }
}

3.2 使用线程池示例

import com.demo.service.DemoService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
import org.springframework.stereotype.Service;

import javax.annotation.Resource;

/**
 * <p> @Title DemoServiceImpl
 * <p> @Description 测试ServiceImpl
 *
 * @author ACGkaka
 * @date 2023/4/24 18:14
 */
@Slf4j
@Service
public class DemoServiceImpl implements DemoService {

    @Resource
    private ThreadPoolTaskExecutor sendSMSThreadPool;

    @Override
    public void sendSMS() {
        // 线程池-发送短信
        sendSMSThreadPool.execute(() -> {
            log.info("Thread: {}, SMS sending...", Thread.currentThread().getName());
        });
    }
}

3.3 执行结果

请求后,日志打印结果如下:

(可以看到线程名称前缀已成功生效。)

Spring(19) ThreadPoolTaskExecutor 线程池的使用,Spring,spring,java,后端

整理完毕,完结撒花~ 🌻





参考地址:

1.Spring线程池ThreadPoolTaskExecutor的使用,https://blog.csdn.net/u012060033/article/details/111934507

2.线程池ThreadPoolTaskExcutor详解,https://juejin.cn/post/7073459521691222024

3.Java线程池详解,https://blog.csdn.net/weixin_40096160/article/details/130542750文章来源地址https://www.toymoban.com/news/detail-805761.html

到了这里,关于Spring(19) ThreadPoolTaskExecutor 线程池的使用的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处: 如若内容造成侵权/违法违规/事实不符,请点击违法举报进行投诉反馈,一经查实,立即删除!

领支付宝红包 赞助服务器费用

相关文章

  • Java线程池的类型和使用

    在并发编程中,线程池是一种非常重要的工具,它可以实现线程的复用,避免频繁地创建新线程,从而提高程序的性能和效率。Java的并发库提供了丰富的线程池功能,本文将介绍Java线程池的类型和使用。 线程池是一种执行多个任务的并发模型。它由一个线程队列和一组可重

    2024年02月13日
    浏览(43)
  • Java中线程池的使用及原理(附带线程池拒绝策略介绍)

    目录 1.使用线程池的目的 2.线程池的使用及原理 3.生动讲解拒绝策略: 4.自己实现一个简单的线程池 5.线程数的决定方法 6.总结 希望各位大佬能多多点赞关注收藏,有了你们的支持,我也能更有动力的向你们学习不是(手动狗头)!!! 在知道线程池之前,每当我们需要一

    2024年04月17日
    浏览(37)
  • Java并发编程学习16-线程池的使用(中)

    上篇分析了在使用任务执行框架时需要注意的各种情况,并简单介绍了如何正确调整线程池大小。 本篇将继续介绍对线程池进行配置与调优的一些方法,详细如下: ThreadPoolExecutor 为 Executors 中的 newCachedThreadPool 、 newFixedThreadPool 和 newScheduledThreadExecutor 等工厂方法返回的 Exe

    2024年02月10日
    浏览(44)
  • Java并发编程学习18-线程池的使用(下)

    上篇介绍了 ThreadPoolExecutor 配置和扩展相关的信息,本篇开始将介绍递归算法的并行化。 还记得我们在《Java并发编程学习11-任务执行演示》中,对页面绘制程序进行一系列改进,这些改进大大地提供了页面绘制的并行性。 我们简单回顾下相关的改进过程: 第一次新增时,页

    2024年02月12日
    浏览(38)
  • springboot自帶线程池ThreadPoolTaskExecutor使用

        不管是阿里,还是华为java开发手册,都会有一条建议,就是让开发者不要使用Executors去创建线程池,而是使用构造函数ThreadPoolExecutor的方式来创建,并设置合理的参数。原因如下:      说明:Executors 返回的线程池对象的弊端如下: 1) FixedThreadPool 和 SingleThreadPool: 允

    2024年02月04日
    浏览(37)
  • Java21 + SpringBoot3使用Spring Security时如何在子线程中获取到认证信息

    目录 前言 原因分析 解决方案 方案1:手动设置线程中的认证信息 方案2:使用 DelegatingSecurityContextRunnable 创建线程 方案3:修改 Spring Security 安全策略 通过设置JVM参数修改安全策略 通过 SecurityContextHolder 修改安全策略 总结 近日心血来潮想做一个开源项目,目标是做一款可以适

    2024年02月19日
    浏览(38)
  • Java线程池的入门

    一、线程池的优势 1.降低系统资源消耗,通过重用已存在的线程,降低线程创建和销毁造成的消耗。 2.提高系统相应速度,当有任务到达时,通过复用已存在的行程,无需等待新线程的创建便能立刻执行。 3.方便线程并发数的管控,因为线程若是无限制创建,可能会导致内存

    2024年02月08日
    浏览(44)
  • Java多线程之线程池的参数和配置

    在Java多线程编程中,线程池是一种常见的技术,用于管理线程的创建和销毁。线程池中的线程可以被重复利用,从而减少了线程的创建和销毁的开销,提高了程序的性能。在Java中,线程池的参数和配置非常重要,不同的参数和配置会影响线程池的性能和行为。 Java线程池的主

    2024年02月16日
    浏览(40)
  • SpringBoot线程池和Java线程池的实现原理

    @ 目录 使用默认的线程池 方式一:通过 @Async 注解调用 方式二:直接注入 ThreadPoolTaskExecutor 线程池默认配置信息 SpringBoot 线程池的实现原理 覆盖默认的线程池 管理多个线程池 JAVA常用的四种线程池 newCachedThreadPool newFixedThreadPool newScheduledThreadPool newSingleThreadExecutor Java 线程池中

    2023年04月11日
    浏览(48)
  • Java 线程池的基本操作

    2024年02月20日
    浏览(39)

觉得文章有用就打赏一下文章作者

支付宝扫一扫打赏

博客赞助

微信扫一扫打赏

请作者喝杯咖啡吧~博客赞助

支付宝扫一扫领取红包,优惠每天领

二维码1

领取红包

二维码2

领红包