springboot线程的用法以及配置详解

news/2024/10/30 11:27:38/

在 Spring Boot 中使用注解设置多线程,一般需要借助 `@Async` 注解和 `ThreadPoolTaskExecutor` 类。

首先,需要在 Spring Boot 应用程序的主类上添加 `@EnableAsync` 注解,该注解表示开启异步执行。

```java
@SpringBootApplication
@EnableAsync
public class MyApplication {
    // ...
}
```

接着,在需要进行多线程执行的方法上添加 `@Async` 注解。该注解表示该方法会在单独的线程中异步执行。

```java
@Service
public class MyService {
    @Async
    public void doSomething() {
        // ...
    }
}
```

如果需要定制线程池的参数,可以使用 `ThreadPoolTaskExecutor` 类。可以在 Spring Boot 的配置文件中设置线程池的参数,也可以在代码中手动创建一个 `ThreadPoolTaskExecutor` 对象。

```java
@Configuration
public class MyConfig {
    @Bean
    public Executor myExecutor() {
        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
        executor.setCorePoolSize(10);
        executor.setMaxPoolSize(20);
        executor.setQueueCapacity(100);
        executor.setThreadNamePrefix("MyExecutor-");
        executor.initialize();
        return executor;
    }
}
```

在上面的代码中,创建了一个名为 `myExecutor` 的线程池,设置了核心线程数为 10,最大线程数为 20,队列容量为 100,线程名称前缀为 `MyExecutor-`。

最后,在需要使用多线程的方法上,使用 `@Async` 注解并指定使用的线程池。

```java
@Service
public class MyService {
    @Async("myExecutor")
    public void doSomething() {
        // ...
    }
}
```

在上面的代码中,使用 `@Async("myExecutor")` 注解指定了使用名为 `myExecutor` 的线程池来执行该方法。

以上是使用注解设置多线程的一个示例,希望对你有所帮助。

 

下面是配置:

@Bean
    public Executor getAsyncExecutor() {
        ThreadPoolTaskExecutor threadPool = new ThreadPoolTaskExecutor();
        //设置核心线程数
        threadPool.setCorePoolSize(Runtime.getRuntime().availableProcessors());
        //设置最大线程数
        threadPool.setMaxPoolSize(Runtime.getRuntime().availableProcessors()*4);
        //线程池所使用的缓冲队列
        threadPool.setQueueCapacity(100000);
        //等待任务在关机时完成->表明等待所有线程执行完
        threadPool.setWaitForTasksToCompleteOnShutdown(true);
        // 等待时间 (默认为0,此时立即停止),并没等待xx秒后强制停止
        threadPool.setAwaitTerminationSeconds(60);
        // 设置线程活跃时间(秒)
        threadPool.setKeepAliveSeconds(60);
        //  线程名称前缀,不设置默认为方法名
        threadPool.setThreadNamePrefix("Async-");
        //拒绝策略
        threadPool.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
        // 初始化线程
        threadPool.initialize();
        return threadPool;这些配置你都讲下

当使用 `@Async` 注解时,Spring Framework 提供了一些默认的线程池配置,但是你可以根据自己的需求自定义线程池,以更好地适应应用程序的性能和资源需求。这里是对上述代码的几个线程池配置的解释:

1. `setCorePoolSize()`:设置核心线程数。当提交一个任务时,如果当前线程数小于核心线程数,则创建新线程执行任务,即使其他空闲线程存在。如果当前线程数大于或等于核心线程数,则将任务放入工作队列。

2. `setMaxPoolSize()`:设置最大线程数。当工作队列已满时,创建新线程执行任务,但线程数不会超过最大线程数。如果设置的最大线程数小于或等于核心线程数,则核心线程数即为最大线程数。

3. `setQueueCapacity()`:设置线程池所使用的缓冲队列的容量。当任务提交时,如果线程池中的线程数已经达到核心线程数,那么任务会被加入到这个缓冲队列中。

4. `setWaitForTasksToCompleteOnShutdown()`:设置线程池在关机时是否等待所有任务完成。如果设置为 true,那么在关闭时会等待所有任务完成之后才会关闭线程池。

5. `setAwaitTerminationSeconds()`:设置线程池关闭的等待时间。如果设置了 `setWaitForTasksToCompleteOnShutdown(true)`,那么在关闭线程池之前会等待所有任务完成。如果在等待的时间内还有任务没有完成,那么这些任务将被强制停止。

6. `setKeepAliveSeconds()`:设置线程的活跃时间。如果线程超过这个时间还没有任务需要执行,那么线程将被关闭。

7. `setThreadNamePrefix()`:设置线程名称前缀。如果不设置,默认为方法名。

8. `setRejectedExecutionHandler()`:设置拒绝策略。当线程池中的线程数已经达到最大线程数,并且工作队列已满时,新的任务将被拒绝执行。可以设置不同的拒绝策略来处理这种情况。例如,`ThreadPoolExecutor.CallerRunsPolicy()` 表示当线程池无法处理任务时,将该任务交给当前线程来处理。

9. `initialize()`:初始化线程池。

10. `Runtime.getRuntime().availableProcessors()`:这个方法返回可用处理器的数目,也就是当前设备的 CPU 核心数。一般情况下,核心数越多,处理器的处理能力就越强,因此可以根据核心数来设置线程池中的核心线程数和最大线程数。

11. `ThreadPoolTaskExecutor`:这个类是 Spring Framework 提供的一个线程池实现类。通过创建这个类的实例,我们可以方便地设置线程池的各种配置,如核心线程数、最大线程数、工作队列容量、拒绝策略、线程名前缀等等。

12. `Bean` 注解:这个注解用于告诉 Spring Framework,这个方法返回的对象需要被注册为一个 bean,可以在其他地方通过依赖注入来使用。

综上所述,这段代码用于创建一个自定义的线程池,用于执行使用

 

 


http://www.ppmy.cn/news/78502.html

相关文章

Spring框架

Spring框架 版本历史核心功能模块控制反转容器(依赖注入)面向切面程序设计数据访问(DAO层支持)事务管理模型-视图-控制器(MVC)远程访问“约定大于配置”的快速应用开发 批处理相关链接参考资料 Spring框架…

【Leetcode hot 100】96. 不同的二叉搜索树

题目链接 思路 动态规划 题目是给定一个有序序列1,2,3…n, 我们需要求出一共有多少种构建二叉搜索树的方法。可以这样考虑:对每一个数字i,我们遍历它,以i为根节点,1…(i-1)为左子树,i1…n为右子树,接着我…

LeetCode——矩阵中移动的最大次数

目录 1、题目 2、题目解读 3、代码 1、题目 2684. 矩阵中移动的最大次数 - 力扣(Leetcode) 给你一个下标从 0 开始、大小为 m x n 的矩阵 grid ,矩阵由若干 正 整数组成。 你可以从矩阵第一列中的 任一 单元格出发,按以下方式遍…

【HackTheBox Bagel】打靶记录

一、namp扫描到5000 8000 22 端口 二、访问8000端口,看到跳转到域名bagel.htb,加入到hosts 看到该url 像文件包含,尝试fuzz一波 尝试找公私钥均未果,找到了cmdline 进一步对其包含 HTTP/1.1 200 OK Server: Werkzeug/2.2.2 …

How to use RestTemplate in Spring boot, part II

How to use RestTemplate in Spring boot, part II Consumer ServicepomControllerBusinessConsumerBusinessConsumerBusinessImpl ResultMaoResultMaoResultCode Request Configapplication.ymlJurongConfigknife4jConfig Summary 考虑到篇幅问题,这里将一篇文章切…

Smartbi电子表格故事之用数据进行销售问题分析

天津小麦商贸有限公司(X&M)成立于2012年11月,主营业务是商贸流通业,主要是日用商品的批发销售。 2012年前,公司创始人(总经理和销售总监)一直从事外贸的生意,自从2008年金融危机…

FreeRTOS学习之路,以STM32F103C8T6为实验MCU(序章——浅谈单片机以及FreeRTOS)

学习之路主要为FreeRTOS操作系统在STM32F103(STM32F103C8T6)上的运用,采用的是标准库编程的方式,使用的IDE为KEIL5。 注意!!!本学习之路可以通过购买STM32最小系统板以及部分配件的方式进行学习…

kubelet源码分析 添加 /删除pod (SyncPod、SyncTerminatingPod、SyncTerminatedPod)篇

kubelet源码分析 添加 /删除pod (SyncPod、SyncTerminatingPod、SyncTerminatedPod) kubelet版本v1.27.1 前面讲过删除pod和添加pod,都是在kubelet文件的的HandlePodAdditions函数和pod_workers.go文件中主要流程。 这篇文章是当pod_workers.go流程结束后&#xf…