Scala 线程安全的 HashSet

Question

使 HashSet 线程安全的可能方法是什么？看到下面给出的一些样本。

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

SynchronizedSet 目前已弃用。任何建议或样本都会非常有帮助。

Answer 1

如 scala.collection.mutable.SynchronizedSet 的API文档建议，您可以使用 java.util.concurrent.ConcurrentHashMap[A, Unit]反而。

如果你想让它看起来像 Set而不是像 Map ，那么您可以使用 java.util.Collections.newSetFromMap在 Map 周围添加一个包装器让它看起来像 Set :

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

然而，这将返回一个 Java Set .您可以将其包装为 scala.collection.mutable.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]