Spring @Async

🕗 发布于 2024-09-28 16:32 spring java 后端

在Spring中可以使用@Async注解标记类或方法，有@Async注解的类会生成代理对象，代理对象会将有@Async注解的方法(异步方法)放在线程池里面异步执行；

@Async注解的方法返回值类型可以是void，也可以是Future类型，如果是普通类型则获取不到异步执行结果；

Spring默认使用的SimpleAsyncTaskExecutor线程池不会重用线程，并且没有最大线程数的限制，在大并发量的时候存在性能问题，所以Spring使用自定义线程池配合@Async注解一起使用；

一简单使用

在配置类中添加@EnableAsync注解；

在业务类中需要异步执行的方法上添加@Async注解；

1.1 方法返回值类型是void

@Configuration
@EnableAsync
public class CommonConfig {

}

@Service
public class OrderService {
    public void printOrderMsgOne() {
        try {
            // 模拟线程任务执行
            Thread.sleep(300);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        System.out.println("\t" + Thread.currentThread().getName()
                + " 输出message one...");
    }

    @Async
    public void printOrderMsgTwo() {
        try {
            // 模拟线程任务执行
            Thread.sleep(10000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        System.out.println("\t" + Thread.currentThread().getName()
                + " 输出message two...");
    }
}

@RestController
@RequestMapping("/order")
public class OrderController {
    @Autowired
    private OrderService orderService;

    @GetMapping("/one")
    public String orderOne() {
        System.out.println(Thread.currentThread().getName()
                + " 线程开始执行任务...");
        System.out.println("输出printOrderMsgOne方法信息: ");
        orderService.printOrderMsgOne();
        System.out.println("输出printOrderMsgTwo方法信息: ");
        orderService.printOrderMsgTwo();
        // 模拟线程任务执行
        try {
            Thread.sleep(3000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        System.out.println(Thread.currentThread().getName()
                + " 线程结束执行任务...");
        return "success";
    }

}

方法执行结果：

http-nio-8081-exec-2 线程开始执行任务...
输出printOrderMsgOne方法信息:
http-nio-8081-exec-2 输出message one...
输出printOrderMsgTwo方法信息:
http-nio-8081-exec-2 线程结束执行任务...
task-1 输出message two...

orderOne方法在http-nio-8081-exec-2线程中执行，printOrderMsgTwo方法在task-1个线程异步执行；

1.2 方法返回值类型是普通类型

@Configuration
@EnableAsync
public class CommonConfig {

}

@Service
public class OrderService {
    public void printOrderMsgOne() {
        try {
            // 模拟线程任务执行
            Thread.sleep(300);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        System.out.println("\t" + Thread.currentThread().getName()
                + " 输出message one...");
    }

    @Async
    public String printOrderMsgTwo() {
        try {
            // 模拟线程任务执行
            Thread.sleep(10000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        System.out.println("\t" + Thread.currentThread().getName()
                + " 输出message two...");
        return "printOrderMsgTwo successfully";
    }
}

@RestController
@RequestMapping("/order")
public class OrderController {
    @Autowired
    private OrderService orderService;

    @GetMapping("/one")
    public String orderOne() {
        System.out.println(Thread.currentThread().getName()
                + " 线程开始执行任务...");
        System.out.println("输出printOrderMsgOne方法信息: ");
        orderService.printOrderMsgOne();
        System.out.println("输出printOrderMsgTwo方法信息: ");
        String str = orderService.printOrderMsgTwo();
        // 模拟线程任务执行
        try {
            Thread.sleep(3000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        System.out.println("异步执行结果: " + str);
        System.out.println(Thread.currentThread().getName()
                + " 线程结束执行任务...");
        return "success";
    }

}

方法执行结果：

http-nio-8081-exec-1 线程开始执行任务...
输出printOrderMsgOne方法信息:
http-nio-8081-exec-1 输出message one...
输出printOrderMsgTwo方法信息:
异步执行结果: null
http-nio-8081-exec-1 线程结束执行任务...
task-1 输出message two...

在orderOne方法中获取不到printOrderMsgTwo方法异步执行的结果，无论printOrderMsgTwo方法在orderOne方法响应之前完成还是之后完成，都获取不到printOrderMsgTwo方法的异步执行结果；

1.3 方法返回值类型是Future

@Configuration
@EnableAsync
public class CommonConfig {

}

@Service
public class OrderService {
    public void printOrderMsgOne() {
        try {
            // 模拟线程任务执行
            Thread.sleep(300);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        System.out.println("\t" + Thread.currentThread().getName()
                + " 输出message one...");
    }

    @Async
    public Future<String> printOrderMsgTwo() {
        try {
            // 模拟线程任务执行
            Thread.sleep(10000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        System.out.println("\t" + Thread.currentThread().getName()
                + " 输出message two...");
        return new AsyncResult<>("printOrderMsgTwo successfully");
    }
}

@RestController
@RequestMapping("/order")
public class OrderController {
    @Autowired
    private OrderService orderService;

    @GetMapping("/one")
    public String orderOne() {
        System.out.println(Thread.currentThread().getName()
                + " 线程开始执行任务...");
        System.out.println("输出printOrderMsgOne方法信息: ");
        orderService.printOrderMsgOne();
        System.out.println("输出printOrderMsgTwo方法信息: ");
        Future<String> future = orderService.printOrderMsgTwo();
        // 模拟线程任务执行
        try {
            Thread.sleep(3000);
            String str = future.get();
            System.out.println("异步执行结果: " + str);
        } catch (InterruptedException | ExecutionException e) {
            e.printStackTrace();
        }
        System.out.println(Thread.currentThread().getName()
                + " 线程结束执行任务...");
        return "success";
    }

}

方法执行结果：

http-nio-8081-exec-2 线程开始执行任务...
输出printOrderMsgOne方法信息:
http-nio-8081-exec-2 输出message one...
输出printOrderMsgTwo方法信息:
task-2 输出message two...
异步执行结果: printOrderMsgTwo successfully
http-nio-8081-exec-2 线程结束执行任务...

orderOne方法在http-nio-8081-exec-2线程中执行，printOrderMsgTwo在task-2线程中执行；

printOrderMsgTwo的方法返回值类型是Future，Future中的get方法是阻塞方法，所以orderOne方法会一直阻塞直到获得异步执行结果才会响应；

二自定义线程池

@Async注解的value属性用来指定使用具体的线程池

@Target({ElementType.TYPE, ElementType.METHOD})
@Retention(RetentionPolicy.RUNTIME)
@Documented
public @interface Async {
    String value() default "";
}

@Configuration
@EnableAsync
public class CommonConfig {

    @Bean("threadPoolOne")
    public ThreadPoolTaskExecutor threadPool() {
        ThreadPoolTaskExecutor threadPool = new ThreadPoolTaskExecutor();
        threadPool.setCorePoolSize(10);
        threadPool.setMaxPoolSize(15);
        threadPool.setQueueCapacity(15);
        threadPool.setKeepAliveSeconds(60);
        return threadPool;
    }

    @Bean("threadPoolTwo")
    public ThreadPoolTaskExecutor threadPoolTwo() {
        ThreadPoolTaskExecutor threadPool = new ThreadPoolTaskExecutor();
        threadPool.setCorePoolSize(10);
        threadPool.setMaxPoolSize(15);
        threadPool.setQueueCapacity(15);
        threadPool.setKeepAliveSeconds(60);
        return threadPool;
    }

}

@Service
public class OrderService {
    public void printOrderMsgOne() {
        try {
            // 模拟线程任务执行
            Thread.sleep(300);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        System.out.println("\t" + Thread.currentThread().getName()
                + " 输出message one...");
    }

    @Async("threadPoolTwo")
    public CompletableFuture<String> printOrderMsgTwo() {
        try {
            // 模拟线程任务执行
            Thread.sleep(10000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        System.out.println("\t" + Thread.currentThread().getName()
                + " 输出message two...");
        return CompletableFuture.completedFuture("printOrderMsgTwo successfully");
    }
}


@RestController
@RequestMapping("/order")
public class OrderController {
    @Autowired
    private OrderService orderService;

    @GetMapping("/one")
    public String orderOne() {
        System.out.println(Thread.currentThread().getName()
                + " 线程开始执行任务...");
        System.out.println("输出printOrderMsgOne方法信息: ");
        orderService.printOrderMsgOne();
        System.out.println("输出printOrderMsgTwo方法信息: ");
        CompletableFuture<String> future = orderService.printOrderMsgTwo();
        // 模拟线程任务执行
        try {
            Thread.sleep(3000);
            String str = future.get();
            System.out.println("异步执行结果: " + str);
        } catch (InterruptedException | ExecutionException e) {
            e.printStackTrace();
        }
        System.out.println(Thread.currentThread().getName()
                + " 线程结束执行任务...");
        return "success";
    }

}

方法执行结果：

http-nio-8081-exec-1 线程开始执行任务...
输出printOrderMsgOne方法信息:
http-nio-8081-exec-1 输出message one...
输出printOrderMsgTwo方法信息:
threadPoolTwo-1 输出message two...
异步执行结果: printOrderMsgTwo successfully
http-nio-8081-exec-1 线程结束执行任务...

orderOne方法用的是http-nio-8081-exec-1线程，printOrderMsgTwo方法用的threadPoolTwo线程池里面的线程；

原文地址：https://blog.csdn.net/weixin_45339291/article/details/142595867

免责声明：本站文章内容转载自网络资源，如本站内容侵犯了原著者的合法权益，可联系本站删除。更多内容请关注自学内容网（zxcms.com）！

上一篇：什么是算力？cpu+显卡吗？
下一篇：海上安全守护者：北斗盒子TD20，为生命护航

DK5V100R20ST1直插TO220F功率12V 3A同步整流芯片
产品概述DK5V100R20ST1是一款简单高效率的同步整流芯片，只有A，K两个功能引脚，分别对应肖特基二极管PN管脚。芯片内部集成了100V功率NMOS管，可以大幅降低二极管导通损耗，提高整机效率，
阅读更多2024-09-30
使用Python实现图形学的环境映射算法
环境映射的基本概念是将物体周围的环境图像映射到物体表面。通过这种方式，物体不仅显示自身的颜色和纹理，还能反射出周围环境的特征，增强其真实感。环境图像采集：获取物体周围的环境图像，通常使用全景图或立方体
阅读更多2024-09-30
刚毕业就做项目经理，现在感觉越做越没动力，还有必要坚持下去吗？
这从 PMP 行业分布情况中也可以看出一二，而且，根据项目管理协会 PMI 的《项目管理就业增长与人才缺口报告（2017—2027）》对全球11个国家的项目导向型就业机会的分析，到了 2027 年，中
阅读更多2024-09-30
828华为云征文｜针对Flexus X实例云服务器的CPU和内存性能测评
是华为云面向广大中小企业和开发者推出的一款创新型柔性算力云服务器。该产品基于华为云独有的柔性计算技术、盘古大模型、擎天软硬协同架构、瑶光云脑等前沿技术，旨在为中小企业提供灵活、高效、品质跃级的云基础设
阅读更多2024-09-30
EtherNET IP 转 Profinet 网关：工业通信的桥梁
该EtherNet/IP转PROFINET网关EtherNet/IP一侧做从站时可连接EtherNet/IP控制器设备，形成EtherNet/IP子网并连接到PROFINET，实现PROFINET控制
阅读更多2024-09-30
leetcode1801. 积压订单中的订单总数
贪心最大/小优先队列和大/小顶堆的对应关系
阅读更多2024-09-30
Java | Leetcode Java题解之第437题路径总和III
Java | Leetcode Java题解之第437题路径总和III
阅读更多2024-09-30
cudnn的section介绍
使用objdump工具查看cuDNNSections:ALLOC用途：这个 section 通常包含构建工具生成的唯一构建 ID。用于调试或验证目的，帮助唯一标识不同的编译版本。.gnu.hash用途
阅读更多2024-09-30
第三篇第20章工程计价数字化与智能化
一种模拟和实现人类智能的技术。分析和处理大量的数据、自动学习和优化模型，实现复杂的任务和决策。深度学习、跨界融合、人机协同、群智开放、自主操控为更经济地从高频率的、大容量的、不同结构和类型的数据中获取
阅读更多2024-09-30
【C语言内存管理】第六章内存对齐
结构体的内存对齐是指将结构体中的各个成员按照其对齐规则合理排列，以保证结构体中的数据在内存中的对齐方式符合硬件要求，这样可以提高数据访问效率。但是需要注意的是，虽然减少了内存使用，但访问未对齐数据可能
阅读更多2024-09-30

Spring @Async

一 简单使用

1.1 方法返回值类型是void

1.2 方法返回值类型是普通类型

1.3 方法返回值类型是Future

二 自定义线程池

相关文章

一简单使用

二自定义线程池