parallelStream中HashSet的线程安全性

Question

在并行流的谓词函数中有效使用最终的HashSet是否安全？

如果不是，那么使用什么样的好数据结构？我没有看到ConcurrentSet ...我想我可以使用ConcurrentHashMap.entrySet()。

从我所能收集的内容来看，即使HashSet没有被修改，最新状态可能在所有线程中都不可用。但也许有一个简单的伎俩，使其可用？

List<Integer> items = Stream 
    .of(1, 2, 3, 4, 5, 6, 7, 8, 9, 10) 
    .collect(Collectors.toList()); 

Set<Integer> exclude = Stream 
    .of(5, 10, 15) 
    .collect(Collectors.toSet()); 

List<Integer> filtered = items 
    .parallelStream() 
    .filter(num -> !exclude.contains(num)) 
    .collect(Collectors.toList()); 

Answer 1

只要您不修改并行线程中的集合，使用您的示例描述的方式应该是完全安全的。