springboot @Async 配置异步线程池

spring @Async 配置异步线程池

一、认识@Async

在Spring Boot中,可以使用@EnableAsync注解来开启异步执行功能。

在配置类或启动类上加上@EnableAsync注解,开启异步执行功能:

@Configuration
@EnableAsync
public class AppConfig {
    // ...
}

之后就可以在方法中使用@Async注解来指定该方法应该在异步线程池中执行。例如:

@Service
public class MyService {

    @Async
    public void doSomethingAsync() {
        // 异步执行的代码
    }
}

在上面的示例中,doSomethingAsync()方法被标记为异步方法,并且将在异步线程池中执行。

@async的默认线程池是SimpleAsyncTaskExecutor。它是一个简单的线程池,每次执行任务时都会创建一个新的线程。这种线程池适用于短期的异步任务,但不适用于长期运行的任务,因为它可能会导致线程资源的浪费和系统负载的增加。

SimpleAsyncTaskExecutor的主要特点如下:

  1. 每次执行任务都会创建一个新的线程,任务执行完毕后线程会被销毁。
  2. 可以设置线程名称前缀,方便调试和监控。
  3. 可以设置线程优先级,但是在大多数情况下,不建议使用线程优先级。
  4. 可以设置线程是否为守护线程,如果设置为守护线程,当所有非守护线程执行完毕后,守护线程会自动退出。
  5. 可以设置线程池大小,但是由于每次执行任务都会创建一个新的线程,因此线程池大小的设置实际上没有意义。

SimpleAsyncTaskExecutor的使用示例:

// 创建SimpleAsyncTaskExecutor
TaskExecutor executor = new SimpleAsyncTaskExecutor();

// 执行异步任务
executor.execute(new Runnable() {
    @Override
    public void run() {
        // 异步任务的代码
    }
});

需要注意的是,SimpleAsyncTaskExecutor不适用于高并发的场景,因为每次执行任务都会创建一个新的线程,线程的创建和销毁会带来一定的开销。

二、配置@Async的线程池

为了适应高并发的场景,我们可以自己配置@async的异步线程池,建议使用ThreadPoolTaskExecutor等线程池实现。

Spring Boot的AsyncConfigurer接口是一个回调接口,用于提供异步执行器的自定义配置。通过实现该接口,可以自定义异步执行器的线程池大小、线程名称前缀、任务拒绝处理等相关参数。

它提供了两个方法来配置异步任务执行的线程池。

  1. getAsyncExecutor方法:返回一个TaskExecutor类型的bean,它提供了默认的线程池配置,比如线程池大小、队列大小、拒绝策略等等。
  2. getAsyncUncaughtExceptionHandler方法:返回一个AsyncUncaughtExceptionHandler类型的bean,用来处理异步任务中未捕获的异常。

这些方法分别提供了异步任务执行的线程池和异常处理的配置。我们可以在应用程序中实现AsyncConfigurer接口并重写这些方法以配置异步任务的线程池和异常处理器。以下是一个示例实现:

@Configuration
@EnableAsync
public class AsyncConfig implements AsyncConfigurer {

   @Override
   public Executor getAsyncExecutor() {
       ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
       executor.setCorePoolSize(10);
       executor.setMaxPoolSize(100);
       executor.setQueueCapacity(10);
       executor.setThreadNamePrefix("AsyncThread-");
       executor.initialize();
       return executor;
   }

   @Override
   public AsyncUncaughtExceptionHandler getAsyncUncaughtExceptionHandler() {
       return new CustomAsyncExceptionHandler();
   }

   private static class CustomAsyncExceptionHandler implements AsyncUncaughtExceptionHandler {

       @Override
       public void handleUncaughtException(Throwable ex, Method method, Object... params) {
           // Custom exception handling code here
       }
   }
}

在上面的示例中,getAsyncExecutor()方法返回一个ThreadPoolTaskExecutor对象,该对象配置了线程池的核心大小、最大大小、队列容量和线程名称前缀。initialize()方法用于初始化线程池。

三、使用其他线程池

@Async还可以使用其他的线程池,只需在@Async的属性中添加其他线程池的@Bean方法名

其他线程池

@Configuration
public class AppConfig {

    @Bean
    public Executor taskExecutor() {
        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
        executor.setCorePoolSize(10);
        executor.setMaxPoolSize(100);
        executor.setQueueCapacity(10);
        executor.setThreadNamePrefix("MyAsyncThread-");
        executor.initialize();
        return executor;
    }
}

然后,在异步执行的方法上,使用@Async注解来标注,并指定线程池名称:

@Service
public class MyService {

    // 指定其他线程池,输入方法名
    @Async("taskExecutor")
    public void doSomethingAsync() {
        // 异步执行的代码
    }
}

这里@Async("taskExecutor")指定了异步执行使用的线程池名称为"taskExecutor",与上面配置的Bean名称一致。

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 216,470评论 6 501
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 92,393评论 3 392
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 162,577评论 0 353
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 58,176评论 1 292
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 67,189评论 6 388
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 51,155评论 1 299
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 40,041评论 3 418
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 38,903评论 0 274
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 45,319评论 1 310
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 37,539评论 2 332
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 39,703评论 1 348
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 35,417评论 5 343
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 41,013评论 3 325
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 31,664评论 0 22
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 32,818评论 1 269
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 47,711评论 2 368
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 44,601评论 2 353