Java concurrentmodificationexception in der Prioritätswarteschlange

Question

Ich habe ein Problem beim Iterieren meiner Prioritätswarteschlange, die Concurrentmodificationexception kostet.

Code für das Iterieren:

Queue<Patient> pq = new PriorityQueue<Patient>(); 
Iterator<Patient> it = pq.iterator();  
      while(iter.hasNext()){ 
       Patient current = iter.next(); 
       if(current.getName().equals(patientName)){ 

        pq.remove(p); 
        } 


       } 

Es Fehler sagt, dass iter.next() ConcurrentModificationException kosten. Darf ich bitte wissen, wie man das löst? Ich habe das Internet gesucht, aber das kann immer noch keine Lösung finden.

Answer 1

Code ändern zu folgenden für die Lösung von it -

Queue<Patient> pq = new PriorityQueue<Patient>(); 
Iterator<Patient> iter = pq.iterator();  
      while(iter.hasNext()){ 
       Patient current = iter.next(); 
       if(current.getName().equals(patientName)){ 

        iter.remove(); 
        } 


       } 

ErklärungConcurrentModificationException von next() -Methode von Iterator geworfen wird, wenn es in der zugrunde liegenden Auflistung (in Ihrem Fall jede strukturelle Veränderung Warteschlange), dh jedes Element wird direkt in der Warteschlange hinzugefügt oder entfernt. Es heißt Fail Fast Iterator.

Answer 2

Try ConcurrentLinkedQueue statt Priorityqueue

zu verwenden Acording: https://docs.oracle.com/javase/7/docs/api/java/util/concurrent/ConcurrentLinkedQueue.html

Beachten Sie, dass, anders als in den meisten Sammlungen ist die Größe Methode nicht ein konstanten Zeitbetrieb. Aufgrund der asynchronen Art dieser Warteschlangen erfordert das Bestimmen der aktuellen Anzahl von Elementen eine Durchquerung der Elemente und kann daher ungenaue Ergebnisse melden, wenn diese Sammlung während des Durchlaufs geändert wird.

Answer 3

Seit Java8 können Sie entfernen mit removeIf, die Teil von Collection Vertrag ist.

Da removeIf Verfahren ein Prädikat nimmt, könnte der Code so einfach sein wie:

priorityQueue.removeIf(patient -> patient.getName().equals(patientName)); 

Wie für die Concurrent Ausnahme, die Sie hatten, das einfach passiert, weil Sie PriorityQueue#remove direkt zu entfernen versucht Aufruf, während Sie bereits waren Iterieren, was den Iterator überflüssig machen würde. Der richtige Weg, um beim Iterieren zu entfernen, ist mit Iterator#next und dann Iterator#remove (das ist eigentlich, was die Standardimplementierung von removeIf tut).