如何自定义 BlockingQueue 的阻塞行为
我想创建一个阻塞队列，该队列根据自定义规则而不是队列中的项目数来阻止生产者。
例如：
Producer 生成一些文件并放入队列中。消费者在经过一些分析后将它们转移到特定位置。
对于上述方案，我希望生产者在队列中文件总数达到某个阈值时等待生成新文件。如果总大小未超过阈值，则队列可以接受任意数量的文件。
答案 1
我可能会子类化一个，例如ArrayBlockingQueue，并添加一个初始化为阈值的简单，并在达到0时启用各种/方法。BlockingQueueCountDownLatchtakeremove
答案 2
我认为您必须自己实现此锁定机制。您可以使用等待/通知或重新进入锁定/条件，一个长变量保存组合长度和一个链接列表保存文件。
推荐
-
Java： ArrayBlockingQueue vs. LinkedBlockingQueue 我认为，在大多数情况下，将比.但是，当数组中始终有足够的空间时，情况就是如此...如果它满了，它是否会表现得那么好就不是很可预测，因为它会阻止试图将数据推送到队列中的线程......
-
java.util.ConcurrentLinkedQueue 我想使用java.util.ConcurrentLinkedQueue作为Servlet的非持久队列。这是来自javadoc的类的简介。 基于链接节点的无界线程安全队列。当许多线程将共享对公共集合的访问权限时，ConcurrentLinkedQueue 是一
-
Java 中的线程安全队列 我想实现一个队列，它被多个线程击中。 这是堆栈位于单例类中。 现在，一个简单的解决方案是同步这个？我想它需要这个作为标准吗？但是，我想优先考虑写信给它。 所以，写入是高优先
-
-
ConcurrentLinkedQueue 的大小 阅读什么位置？我只看到一个 while 循环来重试排队，直到 AtomicReferences 与预期的值/引用匹配。为什么在成功向队列提供值后无法递增 a？ 多谢。