Java方法返回后线程是否仍可运行以执行异步微服务消息发送任务
问题解答
核心问题答复
- 方法返回后你手动启动的独立线程可以正常继续运行,不会受方法返回、主线程结束的影响,你要的「先返回接收确认、后异步发送第二条消息」的需求完全可以实现。
现有代码问题
你当前的代码存在无效写法:@Async注解加在匿名Thread子类的run方法上完全不生效。@Async是Spring框架提供的异步注解,仅对Spring容器管理的Bean的public方法生效,需要配合启动类的@EnableAsync注解使用,写在自定义的匿名线程方法上不会被Spring解析,属于冗余代码可以直接删除。
另外直接new Thread的方式只适合测试场景,生产环境没有线程池管控,大量请求进来会创建过多线程导致内存溢出、CPU占满等问题,不推荐使用。
正确实现方案
方案1:简易实现(仅测试用)
直接删除无效的@Async注解即可,调整后代码逻辑就符合你的需求:方法启动线程后直接返回响应,线程后台执行sendPort2Response和休眠逻辑:
public Port2RequestResponse processPort2Request(Port2Request request) { FMNP getFMNPRequestObject = unmarshalInputRequest(request.getXmlPortMessage()); Port2RequestResponse response = new Port2RequestResponse(); response.setResult(getSuccessResponse(getFMNPRequestObject.getPort().getDonor())); Thread t = new Thread(){ @SneakyThrows public void run(){ sendPort2Response(request); Thread.sleep(10000); } }; t.start(); return response; }
方案2:生产级实现(Spring @Async方式)
- 首先在Spring Boot启动类上加
@EnableAsync注解开启异步功能 - 把异步逻辑抽到单独的Spring管理的Bean中,示例:
@Service public class Port2AsyncService { @SneakyThrows @Async public void sendPort2ResponseAsync(Port2Request request) { sendPort2Response(request); Thread.sleep(10000); } }
- 改造原业务方法,注入上述Bean直接调用异步方法即可:
@Resource private Port2AsyncService port2AsyncService; public Port2RequestResponse processPort2Request(Port2Request request) { FMNP getFMNPRequestObject = unmarshalInputRequest(request.getXmlPortMessage()); Port2RequestResponse response = new Port2RequestResponse(); response.setResult(getSuccessResponse(getFMNPRequestObject.getPort().getDonor())); // 直接调用异步方法,Spring会自动提交到线程池执行,不会阻塞主线程 port2AsyncService.sendPort2ResponseAsync(request); return response; }
这种方式Spring会用内置的线程池管理异步任务,避免资源耗尽问题,适合生产环境使用。
内容的提问来源于stack exchange,提问作者Gavin Coleman
相关产品推荐
相关产品推荐

