视频看了几百小时还迷糊关注我几分钟让你秒懂发点评论可以给博主加热度哦在现代 Java Web 开发中异步处理是提升系统性能、优化用户体验的关键手段。比如用户注册后发送邮件、订单创建后调用第三方接口、日志异步写入等场景都不应阻塞主线程。Spring Boot 原生提供了Async注解来实现异步但存在线程池配置复杂、异常难捕获、任务结果难追踪等问题。这时候AsyncTool就派上用场了一、什么是 AsyncToolAsyncTool 是一个轻量级、高性能的 Java 异步任务编排工具库由国内开发者开源。它支持多任务并行执行任务结果聚合异常统一处理自定义线程池链式调用 回调机制相比 Spring 的AsyncAsyncTool 更灵活、更可控、更适合复杂业务场景。二、需求场景举例假设你正在开发一个“用户下单”功能需要同时做三件事保存订单到数据库必须成功发送短信通知可失败但不能阻塞主流程调用积分系统增加用户积分可失败需记录日志如果用同步方式整个下单可能要 1~2 秒而用异步并行处理主流程只需几十毫秒三、引入依赖Mavendependency groupIdcom.github.dadiyang/groupId artifactIdasync-tool/artifactId version1.0.6/version /dependency四、正确用法示例Spring Boot AsyncTool1. 配置自定义线程池推荐Configuration public class AsyncConfig { Bean(customAsyncExecutor) public ExecutorService customAsyncExecutor() { return new ThreadPoolExecutor( 5, // 核心线程数 10, // 最大线程数 60L, TimeUnit.SECONDS, // 空闲线程存活时间 new LinkedBlockingQueue(100), // 任务队列 new ThreadFactoryBuilder().setNamePrefix(async-tool-pool-).build(), new ThreadPoolExecutor.CallerRunsPolicy() // 拒绝策略主线程执行 ); } }2. 服务层使用 AsyncTool 并行执行任务Service Slf4j public class OrderService { Autowired private ExecutorService customAsyncExecutor; public String createOrder(Long userId, String product) { log.info(开始创建订单用户ID: {}, userId); // 主流程保存订单同步 String orderId saveOrderToDB(userId, product); // 异步并行执行其他任务 AsyncUtil.run(() - sendSms(userId), customAsyncExecutor) .thenRun(() - addPoints(userId), customAsyncExecutor) .exceptionally(throwable - { log.error(异步任务出错, throwable); return null; }); log.info(订单创建完成ID: {}, orderId); return orderId; } private String saveOrderToDB(Long userId, String product) { // 模拟数据库操作 try { Thread.sleep(50); } catch (InterruptedException e) { } return ORDER_ System.currentTimeMillis(); } private void sendSms(Long userId) { log.info(【异步】发送短信给用户: {}, userId); // 模拟网络调用 try { Thread.sleep(200); } catch (InterruptedException e) { } // 故意抛个异常测试 if (userId 999L) { throw new RuntimeException(短信服务不可用); } } private void addPoints(Long userId) { log.info(【异步】为用户 {} 增加积分, userId); try { Thread.sleep(150); } catch (InterruptedException e) { } } }3. Controller 调用RestController RequestMapping(/order) public class OrderController { Autowired private OrderService orderService; PostMapping(/create) public ResponseEntityString createOrder(RequestParam Long userId, RequestParam String product) { String orderId orderService.createOrder(userId, product); return ResponseEntity.ok(orderId); } }五、运行效果请求POST /order/create?userId123product手机日志输出顺序可能不同开始创建订单用户ID: 123 订单创建完成ID: ORDER_1700000000000 【异步】发送短信给用户: 123 【异步】为用户 123 增加积分主线程几乎瞬间返回异步任务在后台执行互不影响六、反例错误使用方式避坑指南❌ 反例1直接使用new Thread().start()// 千万别这么干 new Thread(() - sendSms(userId)).start();问题无法控制线程数量容易 OOM异常无法捕获静默失败没有资源回收浪费系统资源❌ 反例2滥用 SpringAsync且不配置线程池Async // 默认使用 SimpleAsyncTaskExecutor每次新建线程 public void sendEmail(String email) { // ... }问题每次调用都新建线程高并发下服务器崩溃无法统一管理、监控、限流❌ 反例3异步任务中未处理异常AsyncUtil.run(() - { // 可能抛异常的操作 riskyOperation(); }, executor); // 如果 riskyOperation 抛异常这里完全不知道正确做法务必使用.exceptionally()或 try-catch 包裹七、注意事项重要不要在异步任务中处理事务Spring 的事务是基于 ThreadLocal 的异步线程无法继承主线程的事务上下文。如需事务请在异步方法内部开启新事务Transactional(propagation Propagation.REQUIRES_NEW)。线程池必须自定义避免使用默认线程池务必根据业务量设置合理的 corePoolSize、queueSize 和拒绝策略。避免在异步任务中使用 RequestContextHolder异步线程拿不到 HTTP 请求上下文如用户信息、traceId如需传递需手动通过ThreadLocal或参数传入。任务不要无限堆积如果任务生产速度 消费速度队列会爆满。建议配合监控如 Micrometer观察队列长度。测试时注意线程切换单元测试中异步任务可能还没执行完就结束了。可使用CountDownLatch或CompletableFuture.get()等待。八、进阶获取多个异步任务结果CompletableFutureString future1 AsyncUtil.call(() - getSmsResult(), executor); CompletableFutureInteger future2 AsyncUtil.call(() - getPoints(), executor); // 等待所有完成 CompletableFutureVoid all CompletableFuture.allOf(future1, future2); all.join(); // 阻塞等待 String sms future1.get(); Integer points future2.get();总结方案优点缺点new Thread()简单不可控、危险SpringAsync集成方便配置复杂、异常难处理AsyncTool灵活、安全、高性能需额外引入依赖结论对于需要多任务并行、结果聚合、异常兜底的场景强烈推荐使用 AsyncTool视频看了几百小时还迷糊关注我几分钟让你秒懂发点评论可以给博主加热度哦