具有多个消费者线程的Java阻塞队列不公平
我正在使用（java）LinkedBlockingQueue创建资源池，其中
- 资源元素是等价的，属于一个池，它们的排序是无关紧要的。
- 消费者是竞争线程，一次抓取一个资源，使用“拉”操作，处理资源，然后通过“添加”操作将其返回给池。
- 当特定资源被消费者线程使用时，它不得对其他消费者线程可用。
问题是：LinkedBlockingQueue不会对等待的消费者进行FIFO，而且服务水平也不统一。
关于这个话题有什么想法吗？提前谢谢。
共有1个答案
我理解您的情况可能需要这种类型的设计，但重复地从队列中取出资源并将其放回对我来说似乎有点不寻常。
难道你不能简单地拥有一个固定的工作线程池（每个工作线程绑定到其资源）并使用 LinkedBlockingQueue 来分配作业/工作吗？
-
我试图用阻塞队列实现一些消费者-生产者问题。为了达到某种目的，我决定编写文件搜索工具。 我认为搜索机制是递归工作的，每个新目录都将有新的线程池来提高搜索速度。 我的问题是，我不知道如何实现最终停止打印线程(消费者)的机制——当搜索线程完成工作时。 我试图用一些想法来做到这一点，比如毒丸，但它效果不佳（线程在打印任何结果之前停止）。任何想法我该怎么做？ 下面是一些代码： 搜索机制： } 打印机： }
-
我编写了一个简单的类，我计划将其扩展为客户端套接字编程应用程序的一部分。类涉及一个BlockingQueue（我从这里复制了代码：相当于Java的BlockingQueue的C++）。当我创建了下面的包装类的一个实例后，我打算让它生成一个单独的线程，该线程只需执行BlockingQueue上阻塞的printer（）函数，直到有一个或多个字符串可用，然后它只需将字符串打印到控制台窗口。在我的预期应用
-
1. 什么是阻塞队列？ 阻塞队列（BlockingQueue）是一个支持两个附加操作的队列。这两个附加的操作是：在队列为空时，获取元素的线程会等待队列变为非空。当队列满时，存储元素的线程会等待队列可用。阻塞队列常用于生产者和消费者的场景，生产者是往队列里添加元素的线程，消费者是从队列里拿元素的线程。阻塞队列就是生产者存放元素的容器，而消费者也只从容器里拿元素。 阻塞队列提供了四种处理方法 方法\处
-
问题内容： 我想创建某种线程应用程序。但是我不确定在两者之间实现队列的最佳方法是什么。 因此，我提出了两个想法（这两个想法可能都是完全错误的）。我想知道哪种更好，如果它们都烂了，那么实现队列的最佳方法是什么。我关心的主要是这些示例中队列的实现。我正在扩展一个内部类的Queue类，它是线程安全的。下面是两个示例，每个示例有4个类。 主班 消费阶层 生产者类别 队列类 要么 主班 消费阶层 生产者类别
-
下面是我们设置的简化/示意图拓扑 每个节点（服务器）都是一个独立的（无集群）jboss应用服务器(Jboss-as7)，包括消息传递服务器。 消息传递服务器部署许多JMS队列。 每个任务服务器为每个队列部署一个MDB，每个队列有许多使用者。 所有消息生产者使用相同的入站适配器，所有消息使用者使用相同的出站适配器。事实上，所有前端节点都是完全相同的（与所有服务器节点相同，配置相同，部署的工件相同）。
-
问题内容： 我正在为标准Java系统工作，对生产者来说，这有严格的时序要求（1/100秒的毫秒）。 我有一个生产者将内容放置在阻塞队列中，然后一个消费者使用了该内容并将其转储到文件中。当数据不可用时，使用者将阻塞。 显然，阻塞队列是合适的接口，但是如果我想 最小化生产者的成本， 我应该选择哪种实际实现？当我将内容放入队列时，我希望尽可能少地进行诸如锁定和分配之类的事情，而且我不介意消费者是否需要等