Spring WebFlux创建了无阻塞线程池

Posted 2023-01-07

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

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

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

答案

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

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