HashMapから項目を削除するとConcurrentModificationExceptionが発生する

Question

私は接続のArrayListを持つサーバーアプリケーションを持っています。このプログラムは、複数のスレッドを使用します。メインスレッドは、閉じた接続を検出するために間隔でプロセスを実行し、アレイからそれらを削除してガベージコレクションできるようにします。次のように

このプロセスは次のとおりです。

private void cullOtherProcessors() throws Exception { 
    //log.log(Level.FINE,"XMLMessageReciever:cullOtherProcessors"); 
    List<ConnectionAppInterface> toDel = new ArrayList<ConnectionAppInterface>(); 
    for (ConnectionAppInterface cur : m_OtherProcessors.keySet()) { 
     if (cur!=null) { 
      if (cur.isClosed()) { 
       //Connection is closed - we could never send a message over it 
       toDel.add(cur); 
      } 
     } 
    } 
    for (int c=0;c<toDel.size();c++) { 
     log.log(Level.FINE,"**XMLMessageReciever:cullOtherProcessors - removing closed connection"); 
     m_OtherProcessors.remove(toDel.get(c)); 
    } 
} 

私のサーバーは、数ヶ月のカップルのために走ったが、それは次のエラーでクラッシュしたログによると：

08/10/16 01:06:39  calling connect 
08/10/16 01:06:39 **XMLMessageReciever:cullOtherProcessors - removing closed connection 
08/10/16 01:06:39 CloseableThread: End of run for thread Socket.Connect(113726) 
08/10/16 01:06:39  Checking connected 
08/10/16 01:06:39  Active Threads this group: 5 
08/10/16 01:06:39  getting Message Reciever 
08/10/16 01:06:39  Active Threads: 8 
08/10/16 01:06:39  Setting m_establishingCon 
08/10/16 01:06:39  Establishing connection to robertsNode 
Server Failed 
java.util.ConcurrentModificationException 
    at java.util.HashMap$HashIterator.nextNode(HashMap.java:1429) 
    at java.util.HashMap$KeyIterator.next(HashMap.java:1453) 
    at metcarob.com.common.network.xmlprotocol.XMLMessageReciever.cullOtherProcessors(XMLMessageReciever.java:57) 
    at metcarob.com.common.network.xmlprotocol.XMLMessageReciever.LoopIteration(XMLMessageReciever.java:98) 
    at metcarob.com.common.network.xmlprotocol.ConnectionManager.LoopIteration(ConnectionManager.java:48) 
    at metcarob.com.personalservices.singlenodeserver.Main.run(Main.java:138) 
    at metcarob.com.personalservices.singlenodeserver.Main.main(Main.java:398) 

基本的に何かがArrayListに起こりました私はそれを介してループしていた（別の接続が確立されている可能性があります）ので、nextNodeは例外をスローします。

私はそれを回避する最善の方法を見つけようとしています。私は単にエラーをキャッチして無視することを検討しています。ミスしたスレッドは、次のループで単純に取り除かれます。私の提案する解決策は次のとおりです：

private void cullOtherProcessors() throws Exception { 
    //log.log(Level.FINE,"XMLMessageReciever:cullOtherProcessors"); 
    //m_OtherProcessors 
    List<ConnectionAppInterface> toDel = new ArrayList<ConnectionAppInterface>(); 
    try { 
     for (ConnectionAppInterface cur : m_OtherProcessors.keySet()) { 
      if (cur!=null) { 
       if (cur.isClosed()) { 
        //Connection is closed - we could never send a message over it 
        toDel.add(cur); 
       } 
      } 
     } 
    } catch (ConcurrentModificationException e) { 
     log.log(Level.FINE,"**XMLMessageReciever:cullOtherProcessors - ConcurrentModificationException being ignored"); 
    } 
    for (int c=0;c<toDel.size();c++) { 
     log.log(Level.FINE,"**XMLMessageReciever:cullOtherProcessors - removing closed connection"); 
     m_OtherProcessors.remove(toDel.get(c)); 
    } 
} 

私は今このコードをサーバーに戻して、さらに数ヶ月間実行します。

これが問題の良い解決策であるかどうかを知りたいと思います。これが最初に起こるには数カ月かかり、コードは5分ごとに接続をループしますので、接続が頻繁に起こらない可能性は低いと思います。 （私はログを見て参照してください）

それは専門家が考えるものを知っていることは良いでしょう。

**これは、この質問を示唆されたが

それはない「ループ内で削除するときに、コレクションを反復ConcurrentModificationExceptionを避ける」と同じです。私のコードでは、HashMapを反復処理している間にアイテムを削除しないで、代わりにマップを反復して、削除するアイテムを一時配列に格納します。私はその後、配列を通過し、項目を削除します。

Answer 1

あなたはsynchronizedListを使用したほうが良いでしょう： https://docs.oracle.com/javase/8/docs/api/java/util/Collections.html#synchronizedList-java.util.List-

Answer 2

こんにちは、それをループしながら、あなたがm_OtherProcessorsの変更を持っているようです。

私が考えることができる例外をキャッチするよりも2つの解決策があります。

1 - m_OtherProcessorsが小さいオブジェクトでmemが問題でない場合は、HashMap < ...> copy = new HashMap < ..>（m_OtherProcessors）などのオブジェクトのローカルコピーを作成することができます。そしてこのオブジェクトであなたの機能を実行してください。 （コピー中にクラッシュする可能性を避けたい場合は、synchronized（m_OtherProcessors）{HashMap < ...> copy = new HashMap < ..>（m_OtherProcessors）}のようなコピーを行う前に、 ）

2 - メソッドやarrayListを同期させただけなので、このような同期はパフォーマンスが低下しますが、信頼性が向上します。

Answer 3

コレクションのトラバース/読み取り中にデータ変更を実行すると、同時変更の例外が発生します。

これを防止する最も簡単な方法は1つです。 collectionをトラバースするにはiteratorを使用してください。

ex。

Iterator<String> iter = myArrayList.iterator(); 

    while (iter.hasNext()) { 
     String str = iter.next(); 

     if (someCondition) 
      iter.remove(); 
    } 

Answer 4

HashMapそうでなければ、ConcurrentModificationException好きかmemory barriersのために再現するバグが難しいでしょうあなたが複数のスレッドでそれを共有することを想定されていないことを意味し、スレッドセーフコレクションではありません。 ConcurrentModificationExceptionは明らかに悪い習慣であり、それが最終的に壊れたマップにつながる可能性があり、あなたのマップが同時に変更された場合に通知されますあなたのHashMapのガードとして見なければならないために行うべきではありませんキャッチ

および/またはデータの損失が悪化します。

パッケージjava.util.concurrentのスレッドセーフなコレクションを使用する必要があります。スレッドセーフMapが必要な場合は、ConcurrentHashMapを使用することをお勧めします。