javaには "LinkedConcurrentHashMap"データ構造がありますか？

Question

私はLinkedHashMapであり、スレッドセーフなデータ構造が必要です。

どうすればいいですか？

Answer 1

Collections.synchronizedMap(new LinkedHashMap())

Answer 2

あなたは挿入順序を保持し、同期ハッシュマップを取得するにはCollections.synchronizedMapで地図をラップすることができます。これはConcurrentHashMapほど効率的ではなく（ConcurrentMapの余分なインターフェースメソッドを実装していませんが）（いくらか）スレッドセーフな動作を行います。

Googleの強力なコレクションでさえ、まだこの特定の問題を解決していないようです。しかし、問題に取り組もうとしているのはone projectです。

並列処理の例外が発生する可能性があるという意味では、反復処理はまだスレッドセーフではないため、同期についてはいくぶん言います。

Answer 3

ConcurrentHashMapはMapインターフェイスにないいくつかの重要な余分なメソッドを提供しているので、LinkedHashMapをsynchronizedMapでラップするだけで同じ機能が提供されるわけではなく、putIfAbsent ConcurrentHashMapを非常に便利にするメソッド（key、oldValue、newValue）とremove（key、oldValue）を置き換えます。

あなたが望むものを実装しているApacheライブラリがない場合は、おそらくLinkedHashMapを使用し、自分の適切なsynchronized {}ブロックを用意する必要があります。

Answer 4

答えはほとんどありません。ソートされたConcurrentHashMap（LinkedHashMapのようなもの）に相当するものは何もありません。他の人が指摘しているように、Collections.synchronizedMap（-yourmap-）を使用してコレクションをラップすることはできますが、同じレベルのきめの細かいロックは得られません。すべての操作でマップ全体がブロックされます。

マップへのアクセスの周りでsynchronizedを使用すること（そのような場合はもちろん、ダーティリードは気にしないかもしれません）、マップの周りにラッパーを記述して、ロックしないでください。

Answer 5

この問題にはさまざまなアプローチがあります。

Collections.synchronizedMap(new LinkedHashMap()); 

他の回答も示唆していますが、これには注意が必要ないくつかの問題があります。特に、コレクションを反復処理するときにコレクションの同期ロックを保持する必要があり、その反復処理が完了するまで他のスレッドがコレクションにアクセスできないことがよくあります。 （See Java theory and practice: Concurrent collections classes）。たとえば：

new ConcurrentHashMap(); 

を使用して

synchronized(map) { 
    for (Object obj: map) { 
     // Do work here 
    } 
} 

は、おそらくあなたはそれを反復処理するコレクションをロックする必要はありませんよう、より良い選択です。

最後に、より多くの機能プログラミングアプローチを検討したいと思うかもしれません。つまり、マップは本質的に不変であると考えることができます。既存のマップに追加する代わりに、古いマップの内容と新しい追加内容を含む新しいマップを作成します。これは最初はかなり奇妙に聞こえるが、実際は道だScala deals with concurrency and collections

Answer 6

Googleコードで利用できるone implementationがある。サイトの見積もり：

ソフトウェアキャッシュとして使用するための高性能バージョンのjava.util.LinkedHashMap。

デザイン

• 同時リンクリストは、立ち退きの順序を提供するためのConcurrentHashMapを介して実行されます。
• 挿入およびアクセスの順序付き排除ポリシー（FIFO、LRU、およびSecond Chance）をサポートします。

Answer 7

は、Java SE/EE 6以降でのみ使用可能ConcurrentSkipListMapのを、使用することができます。キーは、自然順序付けに従ってソートされているので、順序は整っています。あなたはComparatorを持っているか、Comparableオブジェクトのキーを作る必要があります。リンクされたハッシュマップの動作を模倣するために（反復順序はエントリが追加された順序です）、キーオブジェクトを実装して、指定された他のオブジェクトよりも大きくなるように比較します。 ）。 http://www.ibm.com/developerworks/java/library/j-jtp07233.htmlに記載されているように、ラップされた同期化されたリンク付きハッシュマップでは不十分でした： "synchronizedコレクションラッパー、synchronizedMapおよびsynchronizedListは条件付きスレッドセーフとも呼ばれます。リスト1の最初のスニペットは、共通のput-if-absentイディオムを示しています。エントリがマップにまだ存在しない場合は、追加します。 containsKey（）メソッドが返す時刻とput（）メソッドが呼び出された時刻との間に、同じキーを持つ値を別のスレッドが挿入する可能性があります。正確に一度の挿入を確実にするには、マップmで同期する同期ブロックを持つステートメントのペア。

したがって、通常のConcurrentHashMapより3〜5倍遅いConcurrentSkipListMapが役立ちます。

Answer 8

私は、挿入順に基づいて同期境界付きLRUマップを試しました。LinkedConcurrentHashMap; 同期化のための読み取り/書き込みロックを使用します。 したがって、イテレータを使用しているとき。 ConcurrentModificationExceptionを避けるためにWriteLockを取得する必要があります。
これはより良いですCollections.synchronizedMap.

public class LinkedConcurrentHashMap<K, V> { 

    private LinkedHashMap<K, V> linkedHashMap = null; 
    private final int cacheSize; 
    private ReadWriteLock readWriteLock = null; 

    public LinkedConcurrentHashMap(LinkedHashMap<K, V> psCacheMap, int size) { 
     this.linkedHashMap = psCacheMap; 
     cacheSize = size; 
     readWriteLock=new ReentrantReadWriteLock(); 
    } 

    public void put(K key, V value) throws SQLException{ 
     Lock writeLock=readWriteLock.writeLock(); 
     try{ 
      writeLock.lock(); 
      if(linkedHashMap.size() >= cacheSize && cacheSize > 0){ 
       K oldAgedKey = linkedHashMap.keySet().iterator().next(); 
       remove(oldAgedKey); 
      } 
      linkedHashMap.put(key, value); 
     }finally{ 
      writeLock.unlock(); 
     } 
    } 

    public V get(K key){ 
     Lock readLock=readWriteLock.readLock(); 
     try{ 
      readLock.lock(); 
      return linkedHashMap.get(key); 
     }finally{ 
      readLock.unlock(); 
     } 
    } 

    public boolean containsKey(K key){ 
     Lock readLock=readWriteLock.readLock(); 
     try{ 
      readLock.lock(); 
      return linkedHashMap.containsKey(key); 
     }finally{ 
      readLock.unlock(); 
     } 
    } 

    public V remove(K key){ 
     Lock writeLock=readWriteLock.writeLock(); 
     try{ 
      writeLock.lock(); 
      return linkedHashMap.remove(key); 
     }finally{ 
      writeLock.unlock(); 
     } 
    } 

    public ReadWriteLock getLock(){ 
     return readWriteLock; 
    } 

    public Set<Map.Entry<K, V>> entrySet(){ 
     return linkedHashMap.entrySet(); 
    } 
}