Spring WebFlux 创建无阻塞线程池

Question

我决定用 Java 重写我的 Web 应用程序（以前是在 Python 上）。 在我的应用程序中，我使用了无阻塞 I/O，我有工作池（Celery + Eventlet 线程），我在其中传递由数百个 API 调用组成的任务。

现在我正在使用 Spring WebFlux，但我不明白如何创建一个工作池来将我的任务传递给该池，然后在获得结果并进行一些计算之后。

（我知道创建 ThreadPoolTask​​Executor 的可能性，但线程是阻塞线程）

Answer 1

如果您使用的是非阻塞 API，则无需在特定线程上安排任务 - Reactor 正在为您做这件事。使用 Spring WebFlux，用于处理工作的线程由 Reactor 管理，或者它正在重用 Netty 线程。

查看Schedulers and threading parts of the reactor reference documentation。