如何阻止线程池执行器服务中阻塞队列大小的增加？
假设，我有一个服务A，它有一个线程池执行器来调用服务B。我们可以用自己的值设置该池的核心池大小和队列。现在，服务B对请求的响应速度很慢，因为服务A线程池中的活动线程增加，导致阻塞队列大小增加。如何防止服务A的队列大小增加？
背景
共有1个答案
ThreadPoolExecutor有几个构造函数接受BlockingQueue。
BlockingQueue是一个接口。一种实现是ArrayBlockingQueue，它的大小是有限的。
ThreadPoolExecutor的文档明确提到了这一点：
3.有界队列。有界队列（例如，ArrayBlockingQueue）在与有限最大池大小一起使用时有助于防止资源耗尽，但可能更难调整和控制。...
-
我编写了一个简单的类，我计划将其扩展为客户端套接字编程应用程序的一部分。类涉及一个BlockingQueue（我从这里复制了代码：相当于Java的BlockingQueue的C++）。当我创建了下面的包装类的一个实例后，我打算让它生成一个单独的线程，该线程只需执行BlockingQueue上阻塞的printer（）函数，直到有一个或多个字符串可用，然后它只需将字符串打印到控制台窗口。在我的预期应用
-
我正在编写一个有3个线程的程序。一个读取一个文本文件并将单词输入到大小为2的ArraylistBlockingQueue中。下一个获取该列表并反转其中的每个其他单词。最后一个线程获取单词并将它们写入一个新的文本文件。 我所有的东西都在工作，除了我不知道如何中断和停止我的线程。程序写入文本文件，但从未结束。 主要方法 输入 反向类@重写公共void run（）{ 输出代码@覆盖公共无效run（）{
-
我对一个发布者-多个订阅者模式的实现有疑问。发布者使用固定大小的缓冲区并将消息排队。消息被发送给所有订户。订阅者获取消息的顺序必须与发布消息的顺序相同。 我使用阻止队列来保存发布者消息（发布者队列）并将其传递给每个订阅者阻止队列（订阅者队列）。 问题是缓冲区和订阅服务器工作正常，但缓冲区大小 （发布者Queue.size（）） 始终返回 1。 这是我的完整代码： PublisherSubscrib
-
1. 什么是阻塞队列？ 阻塞队列（BlockingQueue）是一个支持两个附加操作的队列。这两个附加的操作是：在队列为空时，获取元素的线程会等待队列变为非空。当队列满时，存储元素的线程会等待队列可用。阻塞队列常用于生产者和消费者的场景，生产者是往队列里添加元素的线程，消费者是从队列里拿元素的线程。阻塞队列就是生产者存放元素的容器，而消费者也只从容器里拿元素。 阻塞队列提供了四种处理方法 方法\处
-
如另一个问题中所述，当使用Undertow时，所有处理都应该在专用的工作线程池中完成，如下所示： 我知道可用于显式地告诉Undertow在专用的线程池中调度请求以阻止请求。我们可以通过将包装在实例中来修改上面的示例，如下所示： 调用此方法将exchange置于阻塞模式，并创建一个BlockingHttpExchange对象来存储流。当交换处于阻塞模式时，输入流方法变得可用，除了阻塞和非阻塞模式之间
-
问题内容： 我在一个非常简单的生产者-消费者场景中使用 java.util.concurrent.BlockingQueue 。例如，此伪代码描述了使用者部分： 到目前为止，一切都很好。在阻塞队列的javadoc中，我读到： BlockingQueue本质上不支持任何类型的“关闭”或“关闭”操作，以指示将不再添加任何项目。这些功能的需求和使用往往取决于实现。例如，一种常见的策略是让生产者插入特殊的