线程池拒绝策略 CallerRunsPolicy

时间: 2023-08-17 13:06:43 浏览: 118

Java线程池的拒绝策略实现详解

5星 · 资源好评率100%

Java线程池的拒绝策略实现详解 Java线程池的拒绝策略是指当线程池中的线程数量达到最大值时，如何处理新的任务提交的策略。这个策略是由RejectedExecutionHandler接口定义的，提供了四种默认的拒绝策略：CallerRunsPolicy、AbortPolicy、DiscardPolicy和DiscardOldestPolicy。让我们了解一下线程池的基本概念。线程池是池化思想的产物，它的目的是为了提高系统的性能和效率。在Java中，线程池是由ThreadPoolExecutor类实现的，ThreadPoolExecutor类提供了三个重要的参数：corePoolSize、workQueue和maximumPoolSize。corePoolSize是核心线程数，也即最小的线程数；workQueue是阻塞队列，用于存储提交的任务；maximumPoolSize是最大线程数，当提交的任务数大于corePoolSize时，会扩充线程池中线程数，直到达到maximumPoolSize。当提交的任务数大于(workQueue.size() + maximumPoolSize)时，会触发线程池的拒绝策略。RejectedExecutionHandler接口提供了rejectedExecution方法，用于定制具体的拒绝策略的执行逻辑。 Java提供了四种默认的拒绝策略： 1. CallerRunsPolicy：当触发拒绝策略，只要线程池没有关闭的话，则使用调用线程直接运行任务。这适用于并发比较小，性能要求不高，不允许失败的情况。 2. AbortPolicy：丢弃任务，并抛出拒绝执行RejectedExecutionException异常信息。这是线程池的默认拒绝策略。 3. DiscardPolicy：直接丢弃，其他啥都没有。 4. DiscardOldestPolicy：当触发拒绝策略，只要线程池没有关闭的话，丢弃阻塞队列workQueue中的最老的一个任务，并将新任务加入。在实际应用中，我们可以根据不同的需求选择合适的拒绝策略。例如，在高并发的情况下，可以使用CallerRunsPolicy来避免线程池的闭锁；在需要确保所有任务都被执行的情况下，可以使用AbortPolicy来抛出异常信息。让我们通过一个简单的示例代码来演示如何使用ThreadPoolExecutor和RejectedExecutionHandler接口来实现线程池的拒绝策略。 ```java package com.cfang; import java.util.concurrent.BlockingQueue; import java.util.concurrent.LinkedBlockingQueue; import java.util.concurrent.RejectedExecutionHandler; import java.util.concurrent.ThreadPoolExecutor; import java.util.concurrent.TimeUnit; import lombok.extern.slf4j.Slf4j; @Slf4j public class T2 { public static void main(String[] args) throws Exception { int corePoolSize = 5; int maximumPoolSize = 10; long keepAliveTime = 5; BlockingQueue<Runnable> workQueue = new LinkedBlockingQueue<Runnable>(10); RejectedExecutionHandler handler = new ThreadPoolExecutor.AbortPolicy(); ThreadPoolExecutor executor = new ThreadPoolExecutor(corePoolSize, maximumPoolSize, keepAliveTime, TimeUnit.SECONDS, workQueue, handler); // 提交任务 for (int i = 0; i < 20; i++) { executor.execute(new Runnable() { @Override public void run() { log.info("执行任务"); } }); } // 等待所有任务执行完成 executor.shutdown(); executor.awaitTermination(1, TimeUnit.DAYS); } } ``` 在这个示例代码中，我们创建了一个ThreadPoolExecutor实例，并将其配置为使用AbortPolicy拒绝策略。当提交的任务数大于核心线程数和最大线程数之和时，ThreadPoolExecutor将抛出RejectedExecutionException异常信息。

CallerRunsPolicy是线程池的一种拒绝策略，当线程池无法接受新的任务时，它会将任务返回给调用者线程来执行。这种策略的目的是保证数据不会丢失，因为任务会在调用者线程中执行，而不是被丢弃。\[1\]\[2\]在高峰期或者数据处理能力不足的情况下，使用CallerRunsPolicy可能会导致任务堆积，因为任务的执行速度无法跟上任务的提交速度。\[2\]需要注意的是，CallerRunsPolicy中的"调用者线程"指的是主线程，即执行main方法中的代码的线程。\[3\] #### 引用[.reference_title] - *1* *2* [线程池拒绝策略——CallerRunsPolicy](https://blog.csdn.net/qq_22253853/article/details/107050972)[target="_blank" data-report-click={"spm":"1018.2226.3001.9630","extra":{"utm_source":"vip_chatgpt_common_search_pc_result","utm_medium":"distribute.pc_search_result.none-task-cask-2~all~insert_cask~default-1-null.142^v91^control_2,239^v3^insert_chatgpt"}} ] [.reference_item] - *3* [大多数人不知道的：线程池CallerRunsPolicy()拒绝策略](https://blog.csdn.net/weixin_36380516/article/details/120446550)[target="_blank" data-report-click={"spm":"1018.2226.3001.9630","extra":{"utm_source":"vip_chatgpt_common_search_pc_result","utm_medium":"distribute.pc_search_result.none-task-cask-2~all~insert_cask~default-1-null.142^v91^control_2,239^v3^insert_chatgpt"}} ] [.reference_item] [ .reference_list ]

阅读全文

线程池拒绝策略 CallerRunsPolicy

相关推荐

线程池详解：线程池七大核心参数、线程池工作原理、线程池的创建方式、线程池的拒绝策略、如何合理分配线程池大小

Java线程池技术详解

java 线程池 拒绝策略

线程池拒绝策略的应用

Java线程池拒绝策略

springboot 线程池拒绝策略

自定义线程池拒绝策略

线程池拒绝策略保存任务

java线程池拒绝策略new ThreadPoolExecutor.CallerRunsPolicy()

线程池拒绝策略怎么选

java 线程池拒绝策略

线程池拒绝策略 calls

线程池拒绝策略一般怎么设置

线程池拒绝测策略配置

自定义线程池的拒绝策略

线程池的拒绝策略实战

线程池默认的拒绝策略

怎么设置线程池的拒绝策略

线程池拒绝策略 开发中常用什么策略_线程池有哪 4 种拒绝策略？

最新推荐

rime输入法-下载 RIME／中州韻輸入法引擎，是一個跨平臺的輸入法算法框架 基於這一框架，Rime 開發者與其他開源社區的參與者在 Windows、macOS、Linux、Android 等平

深度学习项目-街景字符识别.zip

ruoyi-vue-pro-vben 芋道管理后台，基于 vben 最新版本，最新的 vue3 vite6 ant-design-vue 4.0 typescript 语法进行重构开发

C语言数组操作：高度检查器编程实践

管理建模和仿真的文件

【KUKA系统变量进阶】：揭秘从理论到实践的5大关键技巧

如何使用Python编程语言创建一个具有动态爱心图案作为背景并添加文字'天天开心（高级版）'的图形界面？

基于Swift开发的嘉定单车LBS iOS应用项目解析

"互动学习：行动中的多样性与论文攻读经历"

PROTEUS符号定制指南：个性化元件创建与修改的全面攻略

java 线程池拒绝策略

线程池拒绝策略开发中常用什么策略_线程池有哪 4 种拒绝策略？

rime输入法-下载 RIME／中州韻輸入法引擎，是一個跨平臺的輸入法算法框架基於這一框架，Rime 開發者與其他開源社區的參與者在 Windows、macOS、Linux、Android 等平