HashSet基于HashMap。

如果我们查看HashSet<E>实现,所有内容都在HashMap<E,Object>下管理。

<E>用作HashMap的键。

我们知道HashMap不是线程安全的。这就是为什么我们在Java中有ConcurrentHashMap。

基于此,我很困惑,为什么我们没有一个应该基于ConcurrentHashMap的ConcurrentHashSet ?

我还遗漏了什么吗?我需要在多线程环境中使用Set。

此外,如果我想创建自己的ConcurrentHashSet,我可以通过将HashMap替换为ConcurrentHashMap并保留其余部分来实现它吗?


当前回答

为什么不使用java.util.concurrent中的:CopyOnWriteArraySet ?

其他回答

番石榴15你也可以简单地使用:

Set s = Sets.newConcurrentHashSet();

就像Ray total提到的,这很简单:

Set<String> myConcurrentSet = ConcurrentHashMap.newKeySet();
import java.util.AbstractSet;
import java.util.Iterator;
import java.util.Set;
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.ConcurrentMap;


public class ConcurrentHashSet<E> extends AbstractSet<E> implements Set<E>{
   private final ConcurrentMap<E, Object> theMap;

   private static final Object dummy = new Object();

   public ConcurrentHashSet(){
      theMap = new ConcurrentHashMap<E, Object>();
   }

   @Override
   public int size() {
      return theMap.size();
   }

   @Override
   public Iterator<E> iterator(){
      return theMap.keySet().iterator();
   }

   @Override
   public boolean isEmpty(){
      return theMap.isEmpty();
   }

   @Override
   public boolean add(final E o){
      return theMap.put(o, ConcurrentHashSet.dummy) == null;
   }

   @Override
   public boolean contains(final Object o){
      return theMap.containsKey(o);
   }

   @Override
   public void clear(){
      theMap.clear();
   }

   @Override
   public boolean remove(final Object o){
      return theMap.remove(o) == ConcurrentHashSet.dummy;
   }

   public boolean addIfAbsent(final E o){
      Object obj = theMap.putIfAbsent(o, ConcurrentHashSet.dummy);
      return obj == null;
   }
}

你可以使用guava的Sets.newSetFromMap(map)来获取一个。Java 6在Java .util. collections中也有这个方法

ConcurrentHashSet没有内置类型,因为您总是可以从映射派生一个集。由于有许多类型的映射,您可以使用一个方法从给定的映射(或映射类)生成一个集合。

在Java 8之前,您可以通过使用Collections.newSetFromMap(map)生成由并发哈希映射支持的并发哈希集

在Java 8中(由@Matt指出),您可以通过ConcurrentHashMap.newKeySet()获得并发哈希集视图。这比旧的newSetFromMap稍微简单一点,后者要求您传入一个空的映射对象。但它是特定于ConcurrentHashMap的。

无论如何,Java设计人员可以在每次创建新的映射接口时创建一个新的set接口,但是当第三方创建他们自己的映射时,这种模式是不可能强制执行的。最好使用派生新集合的静态方法;这种方法总是有效的,即使在创建自己的映射实现时也是如此。