Spring 异步正在阻塞并阻止嵌套的异步调用

Question

谁能告诉我有没有一种方法可以使用 Spring 框架的 @Async 注释而不阻塞/等待结果？这是一些代码来澄清我的问题：

@Service
public class AsyncServiceA {

    @Autowired
    private AsyncServiceB asyncServiceB;

    @Async
    public CompletableFuture<String> a() {
        ThreadUtil.silentSleep(1000);
        return asyncServiceB.b();
    }
}


@Service
public class AsyncServiceB {

    @Async
    public CompletableFuture<String> b() {
        ThreadUtil.silentSleep(1000);
        return CompletableFuture.completedFuture("Yeah, I come from another thread.");
    }
}

和配置：

@SpringBootApplication
@EnableAsync
public class Application implements AsyncConfigurer {

    private static final Log LOG = LogFactory.getLog(Application.class);

    private static final int THREAD_POOL_SIZE = 1;

    public static void main(String[] args) {
        SpringApplication.run(Application.class, args);
    }

    @Bean
    public CommandLineRunner commandLineRunner(ApplicationContext ctx) {
        return args -> {
            final AsyncServiceA bean = ctx.getBean(AsyncServiceA.class);
            bean.a().whenComplete(LOG::info);
        };
    }

    @Override
    @Bean(destroyMethod = "shutdown")
    public ThreadPoolTaskExecutor getAsyncExecutor() {
        final ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
        executor.setCorePoolSize(THREAD_POOL_SIZE);
        executor.setMaxPoolSize(THREAD_POOL_SIZE);
        executor.initialize();
        return executor;
    }

    @Override
    public AsyncUncaughtExceptionHandler getAsyncUncaughtExceptionHandler() {
        // omitted
    }
}

当我运行应用程序时，执行程序调用 AsyncServiceA.a() 并离开，但它仍然持有池中的线程，等待 CompletableFuture.get() 方法。由于池中只有一个线程，因此 AsyncServiceB.b() 无法执行。我期望的是线程在执行 AsyncServiceA.a() 之后返回到池中，然后可用于执行 AsyncServiceB.b()。

有办法吗？

注意 1：我也尝试过 ListenableFuture，但结果是一样的。

注意 2：我已经 成功地 手动完成了（没有 @Async），方法是将执行程序分配给每个方法，如下所示：

AsyncServiceA

public CompletableFuture<String> manualA(Executor executor) {
    return CompletableFuture.runAsync(() -> {
        LOG.info("manualA() working...");
        ThreadUtil.silentSleep(1000);
    }, executor)
            .thenCompose(x -> asyncServiceB.manualB(executor));
}

AsyncServiceB

public CompletableFuture<String> manualB(Executor executor) {
    return CompletableFuture.runAsync(() -> {
        LOG.info("manualB() working...");
        ThreadUtil.silentSleep(1000);
    }, executor)
            .thenCompose(x -> CompletableFuture
                    .supplyAsync(() -> "Yeah, I come from another thread.", executor));
}

这里是 ThreadUtil 如果有人想知道的话。

public class ThreadUtil {

    public static void silentSleep(long millis) {
        try {
            Thread.sleep(millis);
        } catch (InterruptedException e) {
            throw new RuntimeException(e);
        }
    }
}

更新：添加了非阻塞异步注释的问题https://jira.spring.io/browse/SPR-15401

Answer 1

自 Spring 3.0 以来，@Async 支持一直是 Spring 的一部分，这是在 Java8（或 7 就此而言）存在之前的方式。尽管在更高版本中添加了对 CompletableFutures 的支持，但它仍然用于方法调用的简单异步执行。（initial implementationreflects/shows的调用）。

为了组合回调和非阻塞操作，异步支持从未被设计或打算。

对于非阻塞支持，您需要等待 Spring 5 及其 reactive/non-blocking 核心，接下来您可以随时 submit a ticket 在异步支持中获得非阻塞支持.

Answer 2

我已经在问题单上回复了 https://jira.spring.io/browse/SPR-15401 但我也会在这里回复以证明 M. Deinum 的回复是合格的。

@Async 凭借其工作方式（通过AOP 修饰方法调用）只能做一件事，就是将整个方法从sync 转为async。这意味着该方法必须是同步的，而不是同步和异步的混合。

所以 ServiceA 做一些休眠然后委托给异步 ServiceB 必须将休眠部分包装在一些@Async ServiceC 中然后在 ServiceB 和 C 上组合。这样 ServiceA 就变成异步的并且不需要有@Async 注释本身..

Spring 异步正在阻塞并阻止嵌套的异步调用

Spring Async is blocking and prevents nested async calls

java

spring

multithreading

asynchronous

nonblocking