Java高并发编程实战，异步注解@Async自定义线程池

男娘i 2023-10-03 23:41 3阅读 0赞

## 一、@Async注解 ##

@Async的作用就是异步处理任务。

在方法上添加@Async，表示此方法是异步方法；  
在类上添加@Async，表示类中的所有方法都是异步方法；  
使用此注解的类，必须是Spring管理的类；  
需要在启动类或配置类中加入@EnableAsync注解，@Async才会生效；  
在使用@Async时，如果不指定线程池的名称，也就是不自定义线程池，@Async是有默认线程池的，使用的是Spring默认的线程池SimpleAsyncTaskExecutor。

默认线程池的默认配置如下：

默认核心线程数：8；  
最大线程数：Integet.MAX\_VALUE；  
队列使用LinkedBlockingQueue；  
容量是：Integet.MAX\_VALUE；  
空闲线程保留时间：60s；  
线程池拒绝策略：AbortPolicy；  
从最大线程数可以看出，在并发情况下，会无限制的创建线程，我勒个吗啊。

也可以通过yml重新配置：

spring:
      task:
        execution:
          pool:
            max-size: 10
            core-size: 5
            keep-alive: 3s
            queue-capacity: 1000
            thread-name-prefix: my-executor

也可以自定义线程池，下面通过简单的代码来实现以下@Async自定义线程池。

## 二、代码实例 ##

Spring为任务调度与异步方法执行提供了注解@Async支持，通过在方法上标注@Async注解，可使得方法被异步调用。在需要异步执行的方法上加入@Async注解，并指定使用的线程池，当然可以不指定，直接写@Async。

### 1、导入POM ###

<dependency>
        <groupId>com.google.guava</groupId>
        <artifactId>guava</artifactId>
        <version>31.0.1-jre</version>
    </dependency>

### 2、配置类 ###

package com.nezhac.config;
    
    import com.google.common.util.concurrent.ThreadFactoryBuilder;
    import org.springframework.context.annotation.Bean;
    import org.springframework.context.annotation.Configuration;
    import org.springframework.scheduling.annotation.EnableAsync;
    import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
    
    import java.util.concurrent.*;
    
    @EnableAsync// 支持异步操作
    @Configuration
    public class AsyncTaskConfig {
    
        /**
         * com.google.guava中的线程池
         * @return
         */
        @Bean("my-executor")
        public Executor firstExecutor() {
            ThreadFactory threadFactory = new ThreadFactoryBuilder().setNameFormat("my-executo