@EnableAsync和@Async开始异步任务支持

时间:2024-10-30 13:35:56

Spring通过任务执行器(TaskExecutor)来实现多线程和并发编程。使用ThreadPoolTaskExecutor可实现一个基于线程池的TaskExecutor.在开发中实现异步任务,我们可以在配置类中添加@EnableAsync开始对异步任务的支持,并在相应的方法中使用@Async注解来声明一个异步任务。
配置类

package ;

import ;

import ;
import ;
import ;
import ;
import ;
import ;
import ;

@Configuration
@ComponentScan({"",""})
//开始异步支持
@EnableAsync
public class AopConfig implements AsyncConfigurer{

    @Override
    public Executor getAsyncExecutor() {
         //线程池
        ThreadPoolTaskExecutor taskExecutor = new ThreadPoolTaskExecutor();
        (5);
        (10);
        (25);
        ();
        return taskExecutor;
    }

    @Override
    public AsyncUncaughtExceptionHandler getAsyncUncaughtExceptionHandler() {
         return null;
    }

}

任务执行service类

package ;

import ;
import ;

@Service
public class TestService2 {

    //声明异步任务
    @Async
    public void executeAsyncTask(Integer i){
         ("执行异步任务:"+i);
    }

    @Async
    public void executeAsyncTask2(Integer i){
         ("执行异步任务2:"+i);
    }

}

测试类

package com.xingguo.logistics.controller;

import org.springframework.context.annotation.AnnotationConfigApplicationContext;

import com.xingguo.logistics.service.aspect.TestService2;

public class TestController {

public static void main(String[] args) {
    AnnotationConfigApplicationContext context = new AnnotationConfigApplicationContext(AopConfig.class);

    TestService2 testService2 = context.getBean(TestService2.class);
    for(int i = 0; i<10; i++){
        testService2.executeAsyncTask(i);
        testService2.executeAsyncTask2(i);
    }
    context.close();

    }
}

测试结果如下:
这里写图片描述
执行结果可以看出,并没有按照顺序来执行。