为何@Asynchronous与Future类未生效？异步调用问题排查

嘿，我来帮你拆解下为啥你的代码没按预期先打印YYY再打印XXX——其实是几个关键细节没处理对：

核心问题1：Future.get()的阻塞调用 #

你在启动异步方法后立刻调用了r.get()，这个方法的特性就是会阻塞当前线程，直到异步任务完全执行完毕。也就是说，主线程会先等着inparallelMethod睡1秒、打印XXX，之后才会继续执行System.out.print("YYY")，完全颠倒了你的预期顺序。

核心问题2：返回无效的Future对象 #

你的inparallelMethod直接返回了null，这违反了EJB异步方法的规范：标记@Asynchronous的方法必须返回一个有效的Future实现（比如EJB提供的AsyncResult）。返回null会让容器无法正确识别和管理异步任务，直接导致异步逻辑失效，任务变成同步执行。

次要问题：Singleton Bean的并发限制 #

你的Bean标记了@Singleton，默认情况下EJB容器会保证Singleton Bean是单线程访问的——同一时间只能有一个线程进入Bean的方法。这意味着即使你用了@Asynchronous，当你测试多个对象时，容器可能也不会真正开启多个并行线程，导致任务还是顺序执行。

修复后的代码示例 #

针对上面的问题，我调整了代码，你可以参考：

package testfuture;

import java.util.concurrent.ExecutionException;
import java.util.concurrent.Future;
import javax.ejb.Asynchronous;
import javax.ejb.Schedule;
import javax.ejb.Singleton;
import javax.ejb.TransactionManagement;
import javax.ejb.TransactionManagementType;
import javax.ejb.AsyncResult;

@Singleton
@TransactionManagement(TransactionManagementType.BEAN)
// 如果需要支持多线程并发访问Singleton，可以加上这个注解
// @ConcurrencyManagement(ConcurrencyManagementType.BEAN)
public class TestFuture {

    @Schedule(minute = "*/1", hour = "*", persistent = false)
    public void start() {
        try{
            // 启动异步任务，此时主线程不会阻塞，直接往下走
            Future<String> r = inparallelMethod(5);
            // 先打印YYY，符合你的预期
            System.out.print("YYY");
            
            // 如果你需要等待异步任务完成再做后续操作，把get()放在打印YYY之后
            // 但如果不需要等待结果，直接删掉这行，让任务在后台执行
            // String result = r.get();
            // System.out.println("异步任务结果：" + result);
        } catch (InterruptedException ie) {
            System.out.print("线程被中断：" + ie.getMessage());
        } 
        // 注意：ExecutionException只有调用get()时才会抛出，所以如果去掉get()，这个catch块可以移除
    }

    @Asynchronous
    public Future<String> inparallelMethod(int i) throws InterruptedException {
        Thread.sleep(1000);
        System.out.print("XXX");
        // 返回合法的AsyncResult，让容器能正确管理异步任务状态
        return new AsyncResult<>("异步任务完成");
    }
}

额外说明 #

1. 如果想测试多个异步任务并行，建议把Bean改成@Stateless（无状态Bean天生支持多线程并发），或者给Singleton加上@ConcurrencyManagement(ConcurrencyManagementType.BEAN)，让容器不限制线程访问。
2. 如果你需要更灵活的异步处理（比如链式调用、回调），可以考虑结合Java的CompletableFuture，不过在EJB环境下，优先使用容器提供的AsyncResult更稳妥。

内容的提问来源于stack exchange，提问作者Nora alshareef