SpringBoot线程池使用详解

SpringBoot线程池使用详解前提摘要:基于Springboot2.1.4.RELEASE▎配置TaskExecutorimportjava.util.concurrent.ThreadPoolExecutor;importorg.springframework.context.annotation.Bean;importorg.springframework.context.annotation.Configuration;importorg.springframework.core.ta…

大家好,又见面了,我是你们的朋友全栈君。

前提摘要:

    基于Springboot 2.1.4.RELEASE

 

▎ 配置TaskExecutor

import java.util.concurrent.ThreadPoolExecutor;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.core.task.TaskExecutor;
import org.springframework.scheduling.annotation.EnableAsync;
import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;

@Configuration
@EnableAsync
public class ThreadPoolConfig {

	@Bean
	public TaskExecutor taskExecutor() {

		ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();

		// 设置核心线程数
		executor.setCorePoolSize(5);

		// 设置最大线程数
		executor.setMaxPoolSize(10);

		// 设置队列容量
		executor.setQueueCapacity(5);

		// 设置线程活跃时间,单位秒
		executor.setKeepAliveSeconds(60);

		// 设置核心线程超时回收
		executor.setAllowCoreThreadTimeOut(true);

		// 设置默认线程名称
		executor.setThreadNamePrefix("IThread-");

		// 设置拒绝策略
		executor.setRejectedExecutionHandler(new ThreadPoolExecutor.DiscardPolicy());

		return executor;

	}
}

▎ 参数解读

● CorePoolSize

核心线程数,核心线程会一直存活,即使没有任务需要处理。当线程数小于核心线程数时,即使现有的线程空闲,线程池也会优先创建新线程来处理任务,而不是直接交给现有的线程处理。

核心线程在allowCoreThreadTimeout被设置为true时会超时退出,默认情况下不会退出。

● MaxPoolSize

当线程数大于或等于核心线程,且任务队列已满时,线程池会创建新的线程,直到线程数量达到maxPoolSize。如果线程数已等于maxPoolSize,且任务队列已满,则已超出线程池的处理能力,线程池会拒绝处理任务而抛出异常。

● queueCapacity
任务队列容量。从maxPoolSize的描述上可以看出,任务队列的容量会影响到线程的变化,因此任务队列的长度也需要恰当的设置。

● keepAliveTime

当线程空闲时间达到keepAliveTime,该线程会退出,直到线程数量等于corePoolSize。如果allowCoreThreadTimeout设置为true,则所有线程均会退出直到线程数量为0。

● allowCoreThreadTimeout
是否允许核心线程空闲退出,默认值为false。

● RejectedExecutionHandler

拒绝策略:当线程数大于MaxPoolSize+queueCapacity被触发:

  ☞ CallerRunsPolicy – 当触发拒绝策略,只要线程池没有关闭的话,则使用调用线程直接运行任务。一般并发比较小,性能要求不高,不允许失败。但是,由于调用者自己运行任务,如果任务提交速度过快,可能导致程序阻塞,性能效率上必然的损失较大

    ☞ AbortPolicy – 丢弃任务,并抛出拒绝执行 RejectedExecutionException 异常信息。线程池默认的拒绝策略。必须处理好抛出的异常,否则会打断当前的执行流程,影响后续的任务执行。

  ☞ DiscardPolicy – 直接丢弃,其他啥都没有

  ☞ DiscardOldestPolicy –  当触发拒绝策略,只要线程池没有关闭的话,丢弃阻塞队列 workQueue 中最老的一个任务,并将新任务加入

 

▎ 线程池执行流程图   图片来源:https://www.cnblogs.com/yw0219/p/8810956.html

SpringBoot线程池使用详解

 

▎ 案例: 使用AbortPolicy拒绝策略,模拟高并发触发异常

☞ TaskExecutor配置

@Bean
public TaskExecutor taskExecutor() {
	ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
	// 设置核心线程数
	executor.setCorePoolSize(5);
	// 设置最大线程数
	executor.setMaxPoolSize(10);
	// 设置队列容量
	executor.setQueueCapacity(5);
	// 设置线程活跃时间,单位秒
	executor.setKeepAliveSeconds(60);
	// 设置核心线程超时回收
	executor.setAllowCoreThreadTimeOut(true);
	// 设置默认线程名称
	executor.setThreadNamePrefix("IThread-");
	// 设置拒绝策略
	executor.setRejectedExecutionHandler(new ThreadPoolExecutor.AbortPolicy());
	return executor;
}

☞ 创建异步任务

ExecutorService

public interface ExecutorService {
	public void exec();
}

ExecutorServiceImpl

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Service;
import com.mote.service.ExecutorService;

@Service("executorService")
public class ExecutorServiceImpl implements ExecutorService {

	private Logger log = LoggerFactory.getLogger(getClass());

	@Override
	@Async
	public void exec() {
		log.info(Thread.currentThread().getName() + "开始执行");

		try {
			// 模拟业务处理耗时
			Thread.sleep(10000);
		} catch (InterruptedException e) {
			e.printStackTrace();
		}
		log.info("<<<<<<<<<<<<<<<<线程执行完毕>>>>>>>>>>>>>>>>");
	}

}

☞ 编写Controller,调用异步任务

ExecutorController

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;
import com.mote.service.ExecutorService;

@RestController
public class ExecutorController {

	@Autowired
	private ExecutorService executorService;

	@GetMapping("/executor")
	public String executor() {
		try {
			executorService.exec();
			return "success";
		} catch (Exception e) {
			e.printStackTrace();
		}
		return "error";
	}
}

 

☞ 打开浏览器,访问Controller接口,不断刷新模拟高并发,观察返回结果,如果出现error说明策略被触发了

SpringBoot线程池使用详解

版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 举报,一经查实,本站将立刻删除。

发布者:全栈程序员-用户IM,转载请注明出处:https://javaforall.cn/151216.html原文链接:https://javaforall.cn

【正版授权,激活自己账号】: Jetbrains全家桶Ide使用,1年售后保障,每天仅需1毛

【官方授权 正版激活】: 官方授权 正版激活 支持Jetbrains家族下所有IDE 使用个人JB账号...

(0)
blank

相关推荐

  • win10开机“正在准备自动修复”,且无法修复你的电脑「建议收藏」

    win10开机“正在准备自动修复”,且无法修复你的电脑「建议收藏」昨天一顿操作,先是快速启动,后来又觉得快速启动没用又关掉了,第二天过来,发现电脑开不起来了,进到里面怎么自动修复不得行,网上大多数的答案是重装,经过半天努力摸索,终于修好了,原理就不想深究了。准备:一个U盘,并且制作PE系统。1、电脑的系统启动设置在U盘启动,进入PE系统2、打开分区工具DiskGenius点硬盘点重建主引导记录MBR(一般在开始菜单都有)3、再返…

  • c2框架编写

    0x00前言由于昨天520,今天又是521,我被朋友圈和qq空间给刷屏了,都在秀对象。一气之下决定把我上次写的nc拿出来使用类进行重构,多实例化几个对象,这下子我也有对象了。0x01一些小插曲

    2021年12月11日
  • 函数模版特化(类模板的实例化在什么阶段)

    本文转自:https://www.cnblogs.com/dracohan/p/3401660.html 转来收藏以便查阅,感谢原作者今天在写代码时,遇到了模板和特化,在网上找了资料后问题呗一一解决,转载此文用于以后查阅,感谢原创者。其中增加了我自己的总结:特化函数与模板函数的区别:(1)、模板函数的T参数只能传入类类型的参数;特化函数的参数只能传入对应的参数类型,基本类型或类类型。…

  • awk用法

    awk用法一、awk文本过滤的基本用法

  • python获取当前时间的时间戳_python将时间戳转化为时间格式

    python获取当前时间的时间戳_python将时间戳转化为时间格式经常遇到处理时间与获取当前时间,之前记录了一版Scala版本的,现在记录一下Python版本的:Tip:导入类importtimeimportdatetime一.获取时间1.获取当前时间now=datetime.datetime.now()printnowprintnow.yearprintnow.monthprintnow.dayprintnow.hourprintnow….

  • 基于matlab的振动模态分析_matlab动力学分析

    基于matlab的振动模态分析_matlab动力学分析2018年第1期时代农机TIMESAGRICULTURALMACHINERY第45卷第1期Vol.45No.12018年1月Jan.2018作者简介:刘鸿智(1988-),男,辽宁沈阳人,硕士研究生,助教,主要研究方向:机械设计及理论、机械制造。基于MATLAB的机械振动分析研究刘鸿智渊鹤壁职业技术学院袁河南鹤壁4580…

    2022年10月15日

发表回复

您的电子邮箱地址不会被公开。

关注全栈程序员社区公众号