线程池ThreadPool工作中的再次思考

2024-05-09 23:38

本文主要是介绍线程池ThreadPool工作中的再次思考,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

ThreadPoolExecutor类实现了ExecutorService接口和Executor接口,可以设置线程池corePoolSize,最大线程池大小maximumPoolSize,拒绝策略。构造方法:

ThreadPoolExecutor(int corePoolSize, int maximumPoolSize,long keepAliveTime, 
TimeUnit unit,BlockingQueue<Runnable> workQueue,RejectedExecutionHandler handler)

参数含义:

corePoolSize: 线程池维护线程的最少数量
maximumPoolSize:线程池维护线程的最大数量
unit: 线程池维护线程所允许的空闲时间的单位
workQueue:线程池所使用的缓冲队列
handler: 线程池对拒绝任务的处理策略

当一个任务通过execute(Runnable)方法欲添加到线程池时:
l 如果此时线程池中的数量小于corePoolSize,即使线程池中的线程都处于空闲状态,也要创建新的线程来处理被添加的任务。
2 如果此时线程池中的数量大于等于 corePoolSize,但是缓冲队列 workQueue未满,那么任务被放入缓冲队列。
3 如果此时线程池中的数量大于corePoolSize,缓冲队列workQueue满,并且线程池中的数量小于maximumPoolSize,建新的线程来处理被添加的任务。
4 如果此时线程池中的数量大于corePoolSize,缓冲队列workQueue满,并且线程池中的数量等于maximumPoolSize,那么通过 handler所指定的策略来处理此任务。
当线程池中的线程数量大于 corePoolSize时,如果某线程空闲时间超过keepAliveTime,线程将被终止。这样,线程池可以动态的调整池中的线程数。

需要注意的是:如果缓冲队列workQueue是采用无界的话,那么maximumPoolSize的设置将无意义。当线程池中的数量大于等于 corePoolSize新的任务会一直添加到缓存队列中。

workQueue常用的是:ArrayBlockingQueue LinkedBlockingQueue等。

常用的拒绝策略:
AbortPolicy
为java线程池默认的阻塞策略,不执行此任务,而且直接抛出一个运行时异常,切记ThreadPoolExecutor.execute需要try catch,否则程序会直接退出。
DiscardPolicy
直接抛弃,任务不执行,空方法
DiscardOldestPolicy
从队列里面抛弃head的一个任务,并再次execute 此task。
CallerRunsPolicy
该策略直接在调用者线程中运行当前被拒绝的任务,但是,调用者线程性能可能急剧下降。

最近在工作中接触到一个比较暴力的线程拒绝策略,引发了比较大的问题,当并发多时,时常导致服务器down掉。
我将工作中的用到的线程池简化为如下:

/*** * @author kxl**/
package test;
import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.BlockingQueue;
import java.util.concurrent.RejectedExecutionHandler;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;
public class WorkThreadPool {private final static int corePoolSize = 2;private final static int maximumPoolSize = 4;private final static int keepAliveTime =3;private final static long waitTime =5;private static ThreadPoolExecutor workers;public static void init() {BlockingQueue<Runnable> workQueue = new LinkedBlockingQueue<Runnable>(1);//有界 队列长度1RejectedExecutionHandler handler = new RejectedExecutionHandler() {public void rejectedExecution(Runnable r,ThreadPoolExecutor executor) {try {Thread.sleep(WorkThreadPool.waitTime);} catch (InterruptedException e) {}executor.execute(r);}};if (workers == null) {workers = new ThreadPoolExecutor(corePoolSize, maximumPoolSize,keepAliveTime, TimeUnit.SECONDS, workQueue,handler);workers.allowCoreThreadTimeOut(true);}}public synchronized static void addTask(Integer  task) {if (workers == null)init();workers.execute(new WorkThread(task));//System.out.println("worder size=="+workers.getPoolSize());}public synchronized static boolean removeTask(Integer publishQueue) {if (workers == null)return false;for (Runnable runnable : workers.getQueue()) {WorkThread pubThread = (WorkThread) runnable;if (publishQueue != null&& publishQueue.equals(pubThread.getTask())) {return workers.remove(runnable);}}return false;}public static void main(String[] args) {for(int i=0;i<200;i++){WorkThreadPool.addTask(i);}}}class WorkThread implements Runnable {public int task;public WorkThread(int i){this.task=i;}public int getTask() {return task;}public void setTask(int task) {this.task = task;}public void run() {System.out.println(Thread.currentThread().getName() + " is running task"+task);try {Thread.sleep(1000);} catch (InterruptedException e) {e.printStackTrace();}}}

上面构建了一个corePoolSize为2 最大线程为4,且缓存队列长度为1。来测试一下改拒绝策略。

这里写图片描述

由上面的结果可以看到添加新任务线程时,进入拒绝策略,又调用executor.execute(r);可以看该源码,里面又将这个任务继续添加进线程任务中,然后又会被执行到拒绝策略,有疑似死循环的迹象。非常不合理的处理方案。

可以考虑用CallerRunsPolicy策略:

RejectedExecutionHandler handler = new RejectedExecutionHandler() {public void rejectedExecution(Runnable r,ThreadPoolExecutor executor) {try {Thread.sleep(WorkThreadPool.waitTime);} catch (InterruptedException e) {}//executor.execute(r);WorkThread pubThread = (WorkThread) r;System.out.println("拒绝策略:"+pubThread.getTask());//上面注释的方法,大量并发时,一直尝试往已经满了的线程池添加任务,一直重复进入拒绝策略(疑似死循环)//主线程去调用  相当于CallerRunsPolicy策略if (!executor.isShutdown()) {r.run();}}};if (workers == null) {workers = new ThreadPoolExecutor(corePoolSize, maximumPoolSize,keepAliveTime, TimeUnit.SECONDS, workQueue,handler);workers.allowCoreThreadTimeOut(true);}

上面的代码相当于

workers = new ThreadPoolExecutor(corePoolSize, maximumPoolSize,keepAliveTime,TimeUnit.SECONDS, workQueue,new ThreadPoolExecutor.CallerRunsPolicy());

我为了打印一些输出,用上面的方式,可以看callerRunsPolicy源码,里面就是通过r.run进行调用的。

这里写图片描述

如上图输出,当进入拒绝策略后,会由调用者线程中(在本例中就是main主线程)去执行被拒绝的任务,而不是像上面的方法,再次添加到线程任务中这么粗暴的方案了。

这篇关于线程池ThreadPool工作中的再次思考的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/974813

相关文章

Go 语言中的select语句详解及工作原理

《Go语言中的select语句详解及工作原理》在Go语言中,select语句是用于处理多个通道(channel)操作的一种控制结构,它类似于switch语句,本文给大家介绍Go语言中的select语... 目录Go 语言中的 select 是做什么的基本功能语法工作原理示例示例 1:监听多个通道示例 2:带

Spring Boot3虚拟线程的使用步骤详解

《SpringBoot3虚拟线程的使用步骤详解》虚拟线程是Java19中引入的一个新特性,旨在通过简化线程管理来提升应用程序的并发性能,:本文主要介绍SpringBoot3虚拟线程的使用步骤,... 目录问题根源分析解决方案验证验证实验实验1:未启用keep-alive实验2:启用keep-alive扩展建

Java终止正在运行的线程的三种方法

《Java终止正在运行的线程的三种方法》停止一个线程意味着在任务处理完任务之前停掉正在做的操作,也就是放弃当前的操作,停止一个线程可以用Thread.stop()方法,但最好不要用它,本文给大家介绍了... 目录前言1. 停止不了的线程2. 判断线程是否停止状态3. 能停止的线程–异常法4. 在沉睡中停止5

kotlin中的模块化结构组件及工作原理

《kotlin中的模块化结构组件及工作原理》本文介绍了Kotlin中模块化结构组件,包括ViewModel、LiveData、Room和Navigation的工作原理和基础使用,本文通过实例代码给大家... 目录ViewModel 工作原理LiveData 工作原理Room 工作原理Navigation 工

Java捕获ThreadPoolExecutor内部线程异常的四种方法

《Java捕获ThreadPoolExecutor内部线程异常的四种方法》这篇文章主要为大家详细介绍了Java捕获ThreadPoolExecutor内部线程异常的四种方法,文中的示例代码讲解详细,感... 目录方案 1方案 2方案 3方案 4结论方案 1使用 execute + try-catch 记录

Spring Boot 中正确地在异步线程中使用 HttpServletRequest的方法

《SpringBoot中正确地在异步线程中使用HttpServletRequest的方法》文章讨论了在SpringBoot中如何在异步线程中正确使用HttpServletRequest的问题,... 目录前言一、问题的来源:为什么异步线程中无法访问 HttpServletRequest?1. 请求上下文与线

在 Spring Boot 中使用异步线程时的 HttpServletRequest 复用问题记录

《在SpringBoot中使用异步线程时的HttpServletRequest复用问题记录》文章讨论了在SpringBoot中使用异步线程时,由于HttpServletRequest复用导致... 目录一、问题描述:异步线程操作导致请求复用时 Cookie 解析失败1. 场景背景2. 问题根源二、问题详细分

Java多线程父线程向子线程传值问题及解决

《Java多线程父线程向子线程传值问题及解决》文章总结了5种解决父子之间数据传递困扰的解决方案,包括ThreadLocal+TaskDecorator、UserUtils、CustomTaskDeco... 目录1 背景2 ThreadLocal+TaskDecorator3 RequestContextH

java父子线程之间实现共享传递数据

《java父子线程之间实现共享传递数据》本文介绍了Java中父子线程间共享传递数据的几种方法,包括ThreadLocal变量、并发集合和内存队列或消息队列,并提醒注意并发安全问题... 目录通过 ThreadLocal 变量共享数据通过并发集合共享数据通过内存队列或消息队列共享数据注意并发安全问题总结在 J

异步线程traceId如何实现传递

《异步线程traceId如何实现传递》文章介绍了如何在异步请求中传递traceId,通过重写ThreadPoolTaskExecutor的方法和实现TaskDecorator接口来增强线程池,确保异步... 目录前言重写ThreadPoolTaskExecutor中方法线程池增强总结前言在日常问题排查中,