So entfernen Sie Elemente aus einer Warteschlange in Java mit einer Schleife

Ich habe eine Daten-Struktur wie diese:

BlockingQueue mailbox = new LinkedBlockingQueue();

Ich versuche, dies zu tun:

for(Mail mail: mailbox)
{
    if(badNews(mail))
    {
        mailbox.remove(mail);
    }
}

Offensichtlich der Inhalt der Schleife stören die Schranken, und ein Fehler wird ausgelöst, so würde ich in der Regel tun dies:

for(int i = 0;  i < mailbox.size(); i++)
{
    if(badNews(mailbox.get(i)))
    {
        mailbox.remove(i);
        i--;
    }
}

Aber leider BlockingQueue ist nicht eine Funktion zu erhalten oder entfernen Sie ein element vom index, also bin ich stecken. Irgendwelche Ideen?

Edit - Ein paar Klarstellungen:
Eines meiner Ziele ist die Aufrechterhaltung der gleichen Reihenfolge so knallen aus dem Kopf und legt es wieder in der Rute ist nicht gut. Auch, obwohl keine anderen threads zu entfernen wird E-mail aus einer mailbox, die Sie hinzufügen, um es, also ich möchte nicht in der Mitte von einem removal-Algorithmus, kann jemand schicken Sie mir eine mail, und dann haben Sie eine Ausnahme auftreten.

Vielen Dank im Voraus!

überprüfen Sie die Antwort, die ich gepostet haben..

InformationsquelleAutor Josh | 2014-10-21

3

Können Sie pop Umfrage und drücken Sie bieten alle Elemente in der queue, bis Sie eine vollständige Schleife über die Warteschlange. Hier ist ein Beispiel:
```
Mail firstMail = mailbox.peek();
Mail currentMail = mailbox.pop();
while (true) {
    //a base condition to stop the loop
    Mail tempMail = mailbox.peek();
    if (tempMail == null || tempMail.equals(firstMail)) {
        mailbox.offer(currentMail);
        break;
    }
    //if there's nothing wrong with the current mail, then re add to mailbox
    if (!badNews(currentMail)) {
        mailbox.offer(currentMail);
    }
    currentMail = mailbox.poll();
}
```
Beachten Sie, dass dieser Ansatz funktioniert nur, wenn dieser code ausgeführt wird, in einem einzigen thread und es gibt keinen anderen thread, der Elemente entfernt, die aus dieser Warteschlange.

Vielleicht müssen Sie prüfen, ob Sie wirklich wollen, um Abfragen oder nehmen Sie die Elemente aus, die BlockingQueue. Ähnlich wie für das Angebot und stellen.

Mehr info:
- Java BlockingQueue nehmen() vs poll()
- LinkedBlockingQueue setzen vs bieten
Anderen weniger buggy Ansatz ist die Verwendung einer temporären Sammlung, die nicht unbedingt gleichzeitig, und speichern Sie die Elemente, die Sie müssen noch in der Warteschlange. Hier ist ein kickoff-Beispiel:
```
List<Mail> mailListTemp = new ArrayList<>();
while (mailbox.peek() != null) {
    Mail mail = mailbox.take();
    if (!badNews(mail)) {
        mailListTemp.add(mail);
    }
}
for (Mail mail : mailListTemp) {
    mailbox.offer(mail);
}
```
- Immer noch OP nicht Benachrichtigen Sie uns, wenn andere threads, entfernen von Elementen aus der Warteschlange.
- nun, ich kann nicht Lesen, die anderen prev Frage, also mir fehlt dieser Kontext.
- Vielleicht bin ich fehlen, dein Punkt, aber nicht peek null zurück, wenn die Warteschlange leer ist (non-blocking)? In früheren version, wenn die Warteschlange leer war, vor dem betreten der Schleife, es würde geworfen haben eine NPE.
- wenn diejenigen sind Ihre Bedingungen, dann ja, wird es. Aber immer noch Sie haben, um es zu testen.
- überprüft den code nach deinem Kommentar und meine Feste große Fehler. Es gibt keine peek äquivalent-Methode, aber nach der überprüfung der Quell-code ist, gilt es eine ReentrantLock vor dem abrufen (aber nicht entfernen) das head-element in der Warteschlange.
- Ok, vielen Dank für all die Hilfe. Ich werde trace-obwohl Sie es, und versuchen herauszufinden, wie es funktioniert.
- Meine Frage ist, warum das Angebot Aussage ist auch nicht direkt vor der Pause. Es sieht aus wie das Letzte element ist, dass Sie nie wieder Hinzugefügt.
- Hinzugefügt das Stück code. Du hast Recht.
- Es ist eine andere Sache, die ich sehe: wenn das erste element entfernt, wird die Schleife nie bricht.
- dies ist nur ein Beispiel. Können Sie sich den code an Ihre Bedürfnisse an. Außerdem können Sie die Markierung aufheben dieser post als Antwort. Es ist sehr spät hier in meinem Land, so habe ich einige Zeit schlafen zu überdenken und eine richtige Lösung für die nächste Zeit. Hinweis: Sie können eine weitere Warteschlange (nicht unbedingt gleichzeitig) zum speichern der Elemente, die Sie doch noch benötigen, dann erneut fügen Sie alle Elemente aus der queue die aktuelle queue.
- Ok, ich denke ich habe eine gute adaption und gerade gebucht es für die überprüfung. Wir danken Ihnen für mich auf dem richtigen Weg!
- Antwort aktualisiert, bietet ein Beispiel für den letzten Ansatz. Bitte lassen Sie mich wissen, von einem anderen problem, aber wahrscheinlich werde ich es überprüfen, in einigen Stunden =\
- Ja, die neue Lösung arbeitet und löst das problem in höchstens 2n Schritten. Es sieht wirklich gut aus. Die, die ich unten geschrieben haben kann es mit nur n Schritte wenn. Ich bin nicht positiv, aber es scheint zu funktionieren. Egal, deine Antwort führt mich zu der Lösung, also bin ich-Kennzeichnung deins richtig. (Und wenn meins falsch ist, bitte lassen Sie mich wissen) Danke!
- Okay, nach studieren der neuen Lösung, die ich sehen, dass sobald der erste Durchlauf gestellt ist und keine Elemente in der queue stehen bleiben, ein anderer thread könnte hinzufügen und wenn dann die alten items wieder Hinzugefügt, Sie sind auf der Rückseite der Warteschlange. Das neue element soll wieder dort statt. Ich gab es ein erneuter Versuch, unter. Vielleicht am besten ist. Was denkst du?
InformationsquelleAutor Luiggi Mendoza

Ich sah über die Lösungen gepostet, und ich glaube, ich fand eine version, dient meine Zwecke. Was denkst du über diese?

int size = mailbox.size();
for(int i = 0; i < size; i++)
{
    Mail currentMail = mailbox.poll();
    if (!badNews(currentMail))
        mailbox.offer(currentMail);
}

Bearbeiten: Eine neue Lösung, kann problemlos. Was Sie Kerle denken?

while(true)
{
    boolean badNewRemains = false;

    for(Mail mail: mailbox)
    {
        if(badNews(mail))
        {
            badNewRemains = true;
            mailbox.remove(mail);
            break;
        }
    }

    if(!badNewRemains)
        break;
}

Die Größe der Warteschlange kann sich ändern, da die anderen threads sind das hinzufügen von mehr E-mails an die queue. Vorsichtig sein auf dieser.
Ja, jetzt sehe ich, dass die Elemente heraus, um, wenn neue Daten ankommen in der Mitte. Ich gab es ein erneuter Versuch vor.

InformationsquelleAutor Josh

Können Sie einfach implementieren queue für Ihren Bedarf. Und Sie müssen, wenn die API nicht über solche features.

Einer wie:

import java.util.Iterator;
import java.util.LinkedList;


class Mail {
    boolean badMail;
}

class MailQueue {
    private LinkedList<Mail> backingQueue = new LinkedList<>();
    private final Object lock = new Object();

    public void push(Mail mail){
        synchronized (lock) {
            backingQueue.addLast(mail);
            if(backingQueue.size() == 1){
                //this is only element in queue, i.e. queue was empty before, so invoke if any thread waiting for mails in queue.
                lock.notify();
            }
        }
    }

    public Mail pop() throws InterruptedException{
        synchronized (lock) {
            while(backingQueue.isEmpty()){
                //no elements in queue, wait.
                lock.wait();
            }
            return backingQueue.removeFirst();
        }
    }

    public boolean removeBadMailsInstantly() {
        synchronized (lock) {
            boolean removed = false;
            Iterator<Mail> iterator = backingQueue.iterator();

            while(iterator.hasNext()){
                Mail mail = iterator.next();
                if(mail.badMail){
                    iterator.remove();
                    removed = true;
                }
            }

            return removed;
        }
    }
}

Den queue implementiert werden thread-sicher ist, ob push oder pop. Sie können auch Bearbeiten Sie die Warteschlange für weitere Operationen. Und es wird zulassen, den Zugang removeBadMailsInstantly Methode durch mehrere threads (thread-safe). Und Sie werden auch lernen Konzepte des multithreading.

Wenn es viele Stücke von E-mail alle mit dieser Klasse und 'private final Object lock = new Object();', werden Sie sich gegenseitig blockieren oder jedes Schloss irgendwie einzigartig sein?
Downvoter, Grund für downvoting?
Im Grunde müssen Sie erstellen eine Instanz dieser MailQueue, und lassen Sie alle Fäden verwenden Sie dieses Beispiel, so gibt es nur eine Sperre, alle threads mit gleichen Schloss.
threads, die fügt in die Warteschlange nie blockieren, immer. Die threads ruft die mails aus der Warteschlange wird der block nur, wenn die E-mail-Warteschlange leer ist. Der thread beseitigt die schlechten mails werden nie blockieren. Sie können Ihre benötigten Methoden für blockierende/nichtblockierende.

InformationsquelleAutor nullptr

Schreibe einen Kommentar

Du musst angemeldet sein, um einen Kommentar abzugeben.