scalaスレッドセーフHashSet

Question

HashSetスレッドを安全にする方法はありますか？下記のサンプルを見た。

var test = new mutable.HashSet[Long] with mutable.SynchronizedSet[Long] 

SynchronizedSetは現在廃止されています。どんな提案やサンプルも非常に役に立ちます。

Answer 1

APIドキュメントのscala.collection.mutable.SynchronizedSetが示すとおり、代わりにjava.util.concurrent.ConcurrentHashMap[A, Unit]を使用できます。あなたはそれがMapようSetの代わりに見えるようにしたい場合は、その後、あなたはそれがSetのように見えるようにMapの周りにラッパーを追加するためにjava.util.Collections.newSetFromMapを使用することができます

：

def createSet[T]() = java.util.Collections.newSetFromMap(
    new java.util.concurrent.ConcurrentHashMap[T, java.lang.Boolean]) 

この意志、しかし、 Java Setを返します。

今

def createSet[T]() = { 
    import scala.collection.JavaConverters._ 
    java.util.Collections.newSetFromMap(
    new java.util.concurrent.ConcurrentHashMap[T, java.lang.Boolean]).asScala 
} 

することができます作成​​し、このように、たとえばLongのために、特定のタイプの要素で設定同期：

は

val set = createSet[Long]