ConcurrentHashMapsでアトミックネストされた反復操作を行う方法は？

Question

は私が持っている他のオブジェクト（sessionCollection）が含まれていて、私は次の反復操作を行う必要がありConcurrentHashMapサブスクリプション：sessionCollection.removeAllSubscriptionsOfSessionは内部（もConcurrentHashMap）のコレクションを介して別の反復操作を行い

subscriptions.values().forEach(sessionCollection -> 
    sessionCollection.removeAllSubscriptionsOfSession(sessionId)); 

をsessionCollection：

// inside SessionCollection: 
private final ConcurrentHashMap<String, CopyOnWriteArrayList<String>> topicsToSessions = 
new ConcurrentHashMap<>(); 

public void removeAllSubscriptionsOfSession(String sessionId) { 
    // Remove sessions from all topics on record 
    topicsToSessions.keySet().forEach(topicSessionKey -> 
    removeTopicFromSession(sessionId, topicSessionKey)); 
} 

この全体的な手順はオミック操作？

Answer 1

ConcurrentHashMapはバッチ処理（forEach*()）を持っていますが、マップ全体に対してアトミックではありません。地図上で一括変更を行う唯一の方法は、必要な同期をすべて自分で実装することです。たとえば、​​ブロックを明示的に使用するか、必要に応じて同期処理を行うマップのラッパー（または拡張子）を作成します。とにかく同期を行う必要があるので、この場合は、単純なHashMapは十分でしょう。

public class SubscriptionsRegistry { 
    private final Map<Integer, SessionCollection> map = new HashMap<>(); 

    public synchronized void removeSubscriptions(Integer sessionId) { 
     map.values().forEach(...); 
    } 

    public synchronized void addSubscription(...) { 
     ... 
    } 

    ... 
} 

をあなたはまた、あなたのSubscriptionsRegistry外に漏れるのトピック・ツー・セッションマップ（少なくともその修正版）を保護したいと思います、誰も適切な同期なしでそれらを変更することはできません。