java hashset 在多线程环境下不能直接使用，必须通过 collections.synchronizedset() 包装或改用 concurrenthashmap.newkeyset() 来保证线程安全。使用包装类时，所有涉及迭代的操作（如 for-each）必须在外部手动同步整个集合对象，否则会出现 concurrentmodificationexception；而基于 concurrenthashmap 的 newkeyset() 则支持细粒度的并发访问，无需额外同步即可安全遍历。
为什么直接调用 HashSet 会引发数据竞争
直接调用 HashSet 的方法会导致内部哈希表结构被破坏或抛出异常。因为 HashSet 底层依赖 HashMap，其操作并非原子性。当多个线程同时修改元素时，可能触发扩容导致链表成环或节点丢失，且在遍历时检测到的结构修改次数与预期不符，从而抛出 ConcurrentModificationException。
import java.util.*;
public class UnsafeExample {
public static void main(String[] args) {
Set<String> set = new HashSet<>();
// 错误示范：多线程直接操作非线程安全的 HashSet
Thread t1 = new Thread(() -> {
for (int i = 0; i < 1000; i++) {
set.add("item-" + i);
}
});
Thread t2 = new Thread(() -> {
for (int i = 1000; i < 2000; i++) {
set.add("item-" + i);
}
});
t1.start();
t2.start();
try { t1.join(); t2.join(); } catch (InterruptedException e) {}
System.out.println(set.size()); // 结果不确定，可能小于2000
}
}
上述代码中，两个线程分别向 set 添加元素。由于 add 方法内部包含检查存在性、计算哈希、插入节点等多个步骤，这些步骤不是原子的。如果线程 A 和 B 同时检测到某个桶为空并尝试插入，可能导致其中一个元素覆盖另一个，或者在扩容时发生死循环（取决于 JDK 版本）。最终输出的大小通常小于预期的 2000，且无法预测具体数值。
立即学习“Java免费学习笔记（深入）”；
你是 TypeScript 项目架构专家，专注于脚手架搭建生产就绪的 Node.js 和前端应用。生成包含现代工具链（pnpm、Vite、Next.js）、类型
如何正确使用 synchronizedSet 进行安全操作
使用 Collections.synchronizedSet() 可以将 HashSet 包装为线程安全版本。该包装类在每个方法调用上加了锁，但迭代器不是 fail-safe 的。因此，在遍历集合时必须显式地同步集合对象本身，以防止在遍历过程中其他线程修改集合结构。
import java.util.*;
public class SafeSynchronizedExample {
public static void main(String[] args) {
Set<String> safeSet = Collections.synchronizedSet(new HashSet<>());
// 添加元素是安全的
safeSet.add("data-1");
safeSet.add("data-2");
// 遍历时必须手动同步
synchronized (safeSet) {
Iterator<String> it = safeSet.iterator();
while (it.hasNext()) {
String item = it.next();
System.out.println(item);
}
}
}
}
在这个例子中，add 操作由包装类内部的锁保护，是线程安全的。但在遍历部分，我们使用了 synchronized (safeSet) 块。这是关键所在：如果不加这个同步块，即使 add 是安全的，遍历时的 iterator() 获取和后续的 next() 调用之间，如果有其他线程调用了 remove 或 add，就会破坏迭代器的状态，导致不可预知的行为或异常。同步块确保了遍历期间集合结构不被修改。
ConcurrentHashMap.newKeySet() 的优势与适用场景
对于高并发场景，推荐使用 ConcurrentHashMap.newKeySet()。它返回一个由 ConcurrentHashMap 支持的 Set 实现，具有更好的并发性能和更简单的使用方式。它的迭代器是弱一致的（weakly consistent），允许遍历过程中看到其他线程的修改，且不需要外部同步。
import java.util.*;
import java.util.concurrent.ConcurrentHashMap;
public class SafeConcurrentKeySetExample {
public static void main(String[] args) {
Set<String> concurrentSet = ConcurrentHashMap.newKeySet();
// 多线程添加
Thread t1 = new Thread(() -> {
for (int i = 0; i < 100; i++) {
concurrentSet.add("concurrent-" + i);
}
});
Thread t2 = new Thread(() -> {
for (int i = 100; i < 200; i++) {
concurrentSet.add("concurrent-" + i);
}
});
t1.start();
t2.start();
try { t1.join(); t2.join(); } catch (InterruptedException e) {}
// 遍历无需同步，安全且高效
concurrentSet.forEach(System.out::println);
System.out.println("Total: " + concurrentSet.size());
}
}
此方案下，forEach 可以直接调用，无需任何同步块。这是因为底层的 ConcurrentHashMap 使用了分段锁或 CAS 操作，保证了并发下的数据结构一致性。虽然遍历时可能看到未完全提交的数据（弱一致性），但对于大多数统计和展示场景来说，这已经足够且性能远高于全局锁方案。如果业务逻辑要求强一致性快照，则应使用 Collections.synchronizedSet 并在同步块内复制一份数据进行处理。
