Wie kann ich die Größe der LinkedTransferQueue einschränken?

Question

Ich implementiere das Producer/Consumer-Muster und verwende die LinkedTransferQueue-Sammlung.

Ich möchte nicht, dass mein Hersteller bestimmte Speicherbeschränkungen überschreitet.

Derzeit bin ich diesen Scheck, sondern aus den documentation, Größe Betrieb erfordert O (N) Traversal. Für meine aktuelle Implementierung ist es in Ordnung,

aber gibt es einen besseren Ansatz als die, die ich derzeit bin?

LinkedTransferQueue<String> producerStringLinkedTransferQueue = new LinkedTransferQueue<String>(); 

if (producerStringLinkedTransferQueue.size() <= 5000) { 
    producerStringLinkedTransferQueue.add(<some data>); 
} 

Answer 1

Wenn Sie wollen nichts tun, wenn Warteschlange voll ist (nicht ersetzen seine älteste Artikel wie zum Beispiel Apache commons Sammlungen CircularFifoQueue der Fall ist), dann können Sie LinkedTransferQueue in Ihrer benutzerdefinierten Klasse wickeln und benötigt Methoden implementieren für Berechnen der Größe der Warteschlange:

public class LimitLinkedTransferQueue<E> { 
    LinkedTransferQueue<E> queue = new LinkedTransferQueue<>(); 
    private final long maxSize; 
    private long size = 0; 

    public LimitLinkedTransferQueue(long maxSize) { 
     super(); 
     this.maxSize = maxSize; 
    } 

    public boolean add(E e) { 
     if (this.size == this.maxSize){ 
      return false; 
     } 
     boolean result = queue.add(e); 
     if (result) { 
      size++; 
     } 
     return result; 
    } 

    public E take() throws InterruptedException { 
     E item = queue.take(); 
     size--; 
     return item; 
    } 
    // other need methods 
}