Wie man ein Element in einer LinkedBlockingQueue festhält?

Question

Ich benutze eine LinkedBlockingQueue in Java und ich möchte ein Element in der Warteschlange halten, bevor Sie es in den Thread freigeben. Mit anderen Worten, ich möchte eine Verzögerung einrichten, bevor ein Element aus der Warteschlange entfernt wird.

private LinkedBlockingQueue<String> testQue = new LinkedBlockingQueue<String>() 
if (position.equals("leader")) { 
    //process this element as the last one 

Ist es möglich, zu tun?

Answer 1

Blick in die Dokumentation für LinkedBlockingQueue: https://docs.oracle.com/javase/8/docs/api/java/util/concurrent/LinkedBlockingQueue.html

E peek() Ruft, aber nicht entfernen, den Kopf dieser Warteschlange oder den Wert null zurück, wenn diese Warteschlange leer ist.

E poll() Ruft den Kopf dieser Warteschlange ab und entfernt ihn oder gibt null zurück, wenn diese Warteschlange leer ist.

E Abfrage (langes Timeout, TimeUnit-Einheit) Ruft den Kopf dieser Warteschlange ab und entfernt ihn, wobei er ggf. auf die angegebene Wartezeit wartet, bis ein Element verfügbar wird.

Sie haben zwei Möglichkeiten:

1. Verwendung peek() Prozess das Element und ein pool() verwenden, wenn Sie fertig sind. Sie können auch eine Thread.sleep(time) zwischen peek() und pool() setzen, wenn Sie wirklich warten wollen, bis es fertig ist.
2. Verwenden Sie poll(long timeout, TimeUnit unit), wenn Sie jetzt wie lange dauert, um das Element zu verarbeiten.