BlockingQueue

Question

Bloke etme davranışı nasıl özelleştirilir Üreticiyi, sıradaki öğe sayısı yerine özelleştirilmiş kurallara göre engelleyen bir engelleme kuyruğu oluşturmak istiyorum. Örneğin

:

Üretici bazı dosyalar oluşturur ve bir sıraya koyar. Tüketici, bazı analizlerden sonra bunları belirli bir yere aktarır.

Yukarıdaki senaryo için, kuyruğa giren toplam dosyaların boyutu eşik değere ulaşırsa, üreticinin yeni dosyalar üretmeyi beklemesini istiyorum. Kuyruk, toplam boyut eşik değerini geçmediğinde herhangi bir sayıda dosyayı kabul edebilir.

Answer 1

Bunu uygulamak zorunda olacağını düşünüyorum 0.

Answer 2

ulaşan zaman muhtemelen ArrayBlockingQueue gibi bir BlockingQueue böyle alt sınıf ve eşik değerine başlatıldı ve çeşitli take/remove yöntemlerini sağlayan basit bir CountDownLatch eklersiniz kilitleme mekanizması kendiniz. Bekleme/bildirme veya ReentrantLock/Koşul, birleşik uzunluğu ve dosyaları tutan bir LinkedList tutan uzun bir değişken kullanabilirsiniz.