So vermeiden ConcurrentModificationException für den Listener-Fall

Question

Mit einer mEventMap, um die Listener für verschiedene Ereignisse zu halten, und hat addListener(), um die Ereignislistener, removeListener() und dispatchEvent() zu den registrierten Listenern zu registrieren.

public void addListener(EventListener listener) { 
    synchronized (mEventMap) { 

     List<WeakReference<EventListener<Event>>> listeners = mEventMap.get(listener.mEventClass); 
WeakReference<EventListener<Event>> listenerRef = new WeakReference<>(
       (EventListener<Event>) listener) 
     … 
     listeners.add(listenerRef); 

     … 
    } 

}

public void removeListener(EventListener listener) { 
    synchronized (mEventMap) { 
     List<WeakReference<EventListener<Event>>> listeners = mEventMap.get(listener.mEventClass); 

     … 
     if (contains(listeners, listener)) { 
       doRemove(listeners, listener); 
      } 
     … 

    } 
} 


public boolean dispatchEvent(Event event) { 
synchronized (mEventMap) { 
    List<WeakReference<EventListener<Event>>> listeners = mEventMap.get(event.getClass()); 
    ListIterator<WeakReference<EventListener<Event>>> listenerIterator = listeners.listIterator(listeners.size()); 
    … 
    while (listenerIterator.hasPrevious()) { 
      WeakReference<EventListener<Event>> listenerItem = listenerIterator.previous(); 
      EventListener<Event> listenerRef = listenerItem.get(); 
      if (listenerRef != null) { 
       listenerRef.onEvent(event); 
      } else { 
       listenerIterator.remove(); 
      } 
     } 

    … 
} 

Anwendungsfall

EventListener<Event> mEventListener = new EventListener<Event>(
     Event.class) { 
    @Override 
    public boolean onEvent(Event event) { 
     eMgr.removeListener(mEventListener); 
     // do something 
    } 
}; 

addEventListener(mEventListener); 

in dispatch(), während es in der Schleife ist das removeListener() aufgerufen wird und bewirkt, dass die ConcurrentModificationException bei listenerItem = listenerIterator. Bisherige();

Frage: Was ist der beste Weg, um den Absturz zu vermeiden, der durch die Änderung der mEventMap-Daten verursacht wird, während jemand darauf iteriert.

Answer 1

Der Ansatz ist zu wählen, ein Flag im Listener-Objekt hinzuzufügen, ‚isRemoved‘. Der removeListener würde also nur diesen Listener markieren, aber er wird in der Liste bleiben bis zum Versandzeitpunkt, der nur an diejenigen versendet, die nicht markiert sind. Und alle markierten werden nach der Dispatch-Schleife aus der Liste entfernt.

Answer 2

Erstellen Sie eine sichere Kopie Ihrer Liste in dispatchEvent vor der Schleife so etwas wie:

List<WeakReference<EventListener<Event>>> listeners 
          = new ArrayList<>(mEventMap.get(event.getClass())); 

Aber bei weitem der beste Ansatz für die Hörer ist CopyOnWriteArrayList zu verwenden, um die Liste der Zuhörer zu verwalten, wie Sie nicht ändern, es ist zu oft und es ist bereits Thread sicher, so dass Sie keine synchronized blocks mehr benötigen.

Answer 3

Ihr Problem ist, dass Sie ein Element aus der Liste entfernen möchten, während es mit einem impliziten Iterator durchlaufen.

Sie konnten das lösen, indem sie explizit einen Iterator:

for (Iterator<EventListener> it = list.iterator(); it.hasNext();) { 
    EventListener el = it.next(); 
    it.remove(); 
} 

Answer 4

Ein anderer Ansatz wäre die Verwendung von Javas eingebauter EventListenerList-Klasse https://docs.oracle.com/javase/8/docs/api/index.html?javax/swing/event/EventListenerList.html. Obwohl es in den javax.swing-Paketen enthalten ist, habe ich festgestellt, dass es für die Ereignisbenachrichtigung im Allgemeinen sehr nützlich ist. Es wird von einem Array unterstützt, verwaltet Listener nach Klasse und löst keine gleichzeitigen Mod-Exceptions aus. Firing ein Ereignis wie das getan:

Object[] listeners = listenerList.getListenerList(); 
    for(int i = listeners.length - 2; i >= 0; i -= 2){ 
     if(listeners[i] == YourListenerClass.class){ 
      ((YourListenerClass)listeners[i + 1]).yourListenerMethod(yourEvent); 
     } 

    }