我决定用 Java 重写我的 Web 应用程序(之前是用 Python 编写的)。
在我的应用程序中,我使用了无阻塞 I/O,我有工作池(Celery + Eventlet 线程),我在其中传递由数百个 API 调用组成的任务。
现在我正在使用Spring WebFlux但我不明白如何创建一个工作池将我的任务传递到该池,然后获得结果并进行一些计算。
(我知道创建 ThreadPoolTaskExecutor 的可能性,但线程正在阻塞线程)
如果您使用非阻塞 API,则无需在特定线程上安排任务 - Reactor 会为您做这件事。使用 Spring WebFlux,用于处理工作的线程由 Reactor 管理,或者重用 Netty 线程。
查看反应堆参考文档的调度程序和线程部分 http://projectreactor.io/docs/core/release/reference/#schedulers.
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)