Как настроить поведение блокировки BlockingQueue

Question

Я хочу создать очередь блокировки, которая блокирует производителя на основе настроенных правил, а не количества элементов в очереди.

Например:

Производитель производит некоторые файлы и помещает их в очередь.Потребитель переносит их в определенное место после некоторого анализа.

В приведенном выше сценарии я хочу, чтобы производитель ждал создания новых файлов, если размер общих файлов в очереди достигает некоторого порогового значения.Очередь может принимать любое количество файлов, если общий размер не превышает пороговое значение.

Answer 1

Я бы, вероятно, подкласса BlockingQueue, такого как ArrayBlockingQueue, и добавил бы простой CountDownLatch, который инициализируется пороговым значением и разрешает различные методы take / remove, когдадостигнув 0.

Answer 2

Я думаю, вам придется реализовать этот механизм блокировки самостоятельно.Вы можете использовать wait / notify или ReentrantLock / Condition, длинную переменную, содержащую объединенную длину, и LinkedList, содержащий файлы.