HashSet基于HashMap。
如果我们查看HashSet<E>实现，所有内容都在HashMap<E,Object>下管理。
<E>用作HashMap的键。
我们知道HashMap不是线程安全的。这就是为什么我们在Java中有ConcurrentHashMap。
基于此，我很困惑，为什么我们没有一个应该基于ConcurrentHashMap的ConcurrentHashSet ?
我还遗漏了什么吗?我需要在多线程环境中使用Set。
此外，如果我想创建自己的ConcurrentHashSet，我可以通过将HashMap替换为ConcurrentHashMap并保留其余部分来实现它吗?
当前回答
番石榴15你也可以简单地使用:
Set s = Sets.newConcurrentHashSet();
其他回答
就像Ray total提到的，这很简单:
Set<String> myConcurrentSet = ConcurrentHashMap.newKeySet();
番石榴15你也可以简单地使用:
Set s = Sets.newConcurrentHashSet();
如上所述，获得可并发HashSet的最佳方法是使用Collections.synchronizedSet()
Set s = Collections.synchronizedSet(new HashSet(...));
这对我来说很管用，我还没看到有人真正指出这一点。
正如Eugene指出的那样，这比目前批准的解决方案效率更低，因为它只是将您的集包装到同步装饰器中，而ConcurrentHashMap实际上实现了低级并发，它可以很好地支持您的集。所以，感谢斯捷潘年科夫先生阐明了这一点。
http://docs.oracle.com/javase/8/docs/api/java/util/Collections.html#synchronizedSet-java.util.Set-
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;
}
}
Set<String> mySet = Collections.newSetFromMap(new ConcurrentHashMap<String, Boolean>());
