Spring WebFlux创建无阻塞线程池
我决定在Java上重写我的Web应用程序（以前是在Python上）。在我的应用程序中，我使用无阻塞I/O，我有工作池（Celery Eventlet线程），我在其中传递由数百个API调用组成的任务。
现在我正在使用Spring WebFlux，但我不明白如何创建一个工作人员池来将我的任务传递到该池，并在获得结果并进行一些计算之后。
（我知道创建ThreadPoolTaskExecutor的可能性，但线程正在阻塞线程）
共有1个答案
如果您使用的是非阻塞API，则不需要在特定线程上调度任务——Reactor正在为您这样做。使用Spring WebFlux，用于处理工作的线程由Reactor管理，或者它正在重用网状线程。
检查Reactor参考留档的调度程序和Thread部分。
-
我有4-5个工作线程处理大型消息队列。我还有另一段代码，它使用2-3个worker运行。我想在处理大型消息队列时阻止所有其他工作者。 我正在使用JDK6和Jms 编辑： 队列进程工作者从未终止。当没有消息时，它们阻塞队列。这些工作者由执行器线程池管理，如果我使用读写锁，其中一个工作者也会被阻塞。此外，如果使用循环屏障，那么我必须终止线程，以便重新传递阻塞的第二个进程。由于工作者是由线程池管理的，所
-
我编写了一个简单的类，我计划将其扩展为客户端套接字编程应用程序的一部分。类涉及一个BlockingQueue（我从这里复制了代码：相当于Java的BlockingQueue的C++）。当我创建了下面的包装类的一个实例后，我打算让它生成一个单独的线程，该线程只需执行BlockingQueue上阻塞的printer（）函数，直到有一个或多个字符串可用，然后它只需将字符串打印到控制台窗口。在我的预期应用
-
背景我使用log4j2（2.12.1）与同步根和异步记录器。Lmax环形缓冲区大小默认为256*1024。我在控制台的appender。我用JSON布局记录MapMessage。我的日志消息的平均大小约为100字节。 有了上面的细节，我注意到很少有线程被阻塞在 我的问题是。。 环形缓冲区是否很快就满了，这导致主线程背压（在我的例子中，servlet容器线程是http-nio-8080-exec-1
-
我正在尝试用Python编写一个程序。我想写的是一个脚本，它会立即向用户返回一条友好的消息，但会在后台生成一个长的子进程，它会处理几个不同的文件，并将它们写入一个祖父文件。我已经做了一些关于线程和处理的教程，但我遇到的是，无论我尝试什么，程序都会一直等待，直到子进程完成，然后才会向用户显示前面提到的友好消息。以下是我尝试过的： 线程示例： 我读过这些关于多线程的SO帖子如何在Python中使用线程
-
摘要 本文描述了使用 QEMU 运行 RT-Thread 提供的基于多线程的非阻塞 socket 编程示例。 简介 随着物联网的发展，越来越多产品需要基于网络进行数据传输。在实际开发中，往往要求网络传输时不能阻塞当前线程，以致无法及时处理其他消息。在用户无法直接套用简单的 socket demo 时，RT-Thread 提供基于多线程的非阻塞 socket 编程示例，方便用户进行应用程序开发。 在
-
我有下面的代码片段，它试图在多个子进程之间分割处理。 while循环中的主进程正在调用search函数，如果队列达到阈值计数，则处理池将映射到进程函数，其中作业来自队列。我的问题是，python多处理池是在执行期间阻塞主进程，还是立即继续执行？我不想遇到这样的情况，“has_jobs_to_process（）”的计算结果为true，并且在处理作业的过程中，另一组作业的计算结果为true，并且再次调