setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());

时间: 2024-05-26 10:10:10 浏览: 40

Java+常用方法+自用

根据提供的文件信息，以下是从标题、描述、标签以及部分内容中提取和整理的相关IT知识点： ### Java自定义线程池配置及使用详解 #### 一、线程池简介线程池是多线程环境中用于管理和控制线程的一种机制。通过线程池可以有效地管理线程生命周期，提高响应速度和系统吞吐量，减少线程创建和销毁带来的开销。 #### 二、创建自定义线程池在Java中，通常使用`java.util.concurrent.Executor`接口和其实现类`ThreadPoolTaskExecutor`或`ThreadPoolExecutor`来创建线程池。 ##### 示例代码分析： ```java @Configuration @EnableAsync public class ExecutorConfig { @Bean public Executor asyncServiceExecutor() { ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor(); // 配置核心线程数 executor.setCorePoolSize(4); // 配置最大线程数 executor.setMaxPoolSize(8); // 配置队列大小 executor.setQueueCapacity(2000); // 配置线程池中的线程的名称前缀 executor.setThreadNamePrefix("asyncService-"); // rejection-policy：当 pool 已经达到 max size 的时候，如何处理新任务 // CALLER_RUNS：不在新线程中执行任务，而是由调用者所在的线程来执行 executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy()); // 执行初始化 executor.initialize(); return executor; } } ``` - **配置说明**： - `@Configuration` 和 `@EnableAsync` 注解表示这是一个Spring配置类，并启用异步支持。 - `ThreadPoolTaskExecutor` 是Spring提供的一个实现`Executor`接口的类，它可以被Spring容器管理。 - `setCorePoolSize(4)`：设置核心线程数为4。这是线程池中一直保持运行的最小线程数。 - `setMaxPoolSize(8)`：设置最大线程数为8。这是线程池能够创建的最大线程数。 - `setQueueCapacity(2000)`：设置队列容量为2000。这代表线程池等待队列的最大长度。 - `setThreadNamePrefix("asyncService-")`：设置线程名前缀，便于跟踪和管理。 - `setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy())`：设置拒绝策略为`CallerRunsPolicy`。这意味着如果提交的任务无法处理时，该任务将由调用者的线程来执行。 #### 三、线程池核心参数线程池的核心参数包括但不限于以下几点： - `corePoolSize`：核心线程数 - `maximumPoolSize`：最大线程数 - `keepAliveTime`：线程空闲时间 - `unit`：时间单位 - `workQueue`：任务队列 - `threadFactory`：线程工厂 - `handler`：拒绝策略 #### 四、使用示例 ```java @Service public class XXXServiceImpl { @Autowired private Executor asyncServiceExecutor; // 异步处理业务逻辑 asyncServiceExecutor.execute(() -> { try { // 保存责任人的小微、产业人岗客 ruleEngineWorkOrderPersonService.saveWorkOrderPersonXwAndIndustry(workOrder.getReceiveUserCode(), workOrder.getId()); } catch (Exception e) { e.printStackTrace(); } }); } ``` - **使用说明**： - 使用`@Autowired`注解自动装配了`Executor`实例。 - `execute()`方法用于提交一个`Runnable`任务到线程池中执行。 #### 五、自定义线程池示例（另一种） ```java @Configuration public class WebMvcConfig implements WebMvcConfigurer { @Bean(name = "asyncTaskThreadPool") public ThreadPoolExecutor asyncTaskThreadPool() throws Exception { ThreadPoolExecutor threadPool = new ThreadPoolExecutor( 10, // 核心线程数-corePoolSize 2 // 这里似乎缺少了最大线程数的信息 ); return threadPool; } } ``` - **配置说明**： - 此处创建了一个`ThreadPoolExecutor`实例。 - `@Bean`注解用于声明一个可注入的组件。 - `ThreadPoolExecutor`构造函数需要更多参数，例如最大线程数等，这里仅给出了部分信息。通过上述内容，我们了解到Java中线程池的基本概念、配置方式及其使用方法。合理地配置线程池对于优化程序性能具有重要意义。

这是Java多线程中的一个方法，用于设置线程池的拒绝策略为"CallerRuns"，意味着当线程池中的任务队列已满并且无法接受新的任务时，调用线程会自行运行该任务而不是直接抛出RejectedExecutionException异常。哈哈，这让我想起了一个笑话：为什么 Java 程序员总是喜欢用十六进制呢？因为他们喜欢在别人看不懂的时候显摆自己的聪明才智啊！不过开玩笑，十六进制是非常方便的编码方式。那么，您还有其他问题需要我回答吗？

阅读全文

setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());

相关推荐

Spring Boot 配置和使用多线程池的实现

spring boot 多线程.docx

executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());

使用ThreadPoolExecutor 还是使用 ThreadPoolTaskExecutor

@Scheduled设置线程池

ThreadPoolTaskExecutor单例实现

springboot线程池

java springboot创建线程池

springboot如何整合线程池代码例子

在Java中使用一个固定线程池如何配置一个拒绝策略

springboot如何管理线程池

spring ThreadPoolTaskExecutor 异常处理

提供一个ThreadPoolTaskExecutor的配置

ThreadPoolTaskExecutor

ThreadPoolTaskExecutor初始化

springboot 线程池异步自定义异常抛出

ThreadPoolTaskExecutor自定义线程池

最新推荐

spring boot使用自定义配置的线程池执行Async异步任务

SpringBoot异步调用方法并接收返回值

Spring Boot中配置定时任务、线程池与多线程池执行的方法

基于JAVA+SpringBoot+MySQL的校园台球厅人员与设备管理系统设计与实现.docx

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

管理建模和仿真的文件

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

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

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

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