如何在并行流中通过map正确收集得到Set<String>？

你当前的代码用map()时，每个Tree被转换成了一个Stream<String>（对应该Tree的所有节点名），因此最终收集到的是这些子流的集合Set<Stream<String>>，而非你需要的节点名字符串集合。要解决这个问题，核心是用flatMap()替代map()，它能将多个子流合并为一个全局的字符串流，从而直接收集所有节点名。

正确实现代码 #

方案1：获取普通线程安全Set #

Set<String> nodeNames = trees.parallelStream()
    .flatMap(tree -> tree.getNodes().stream()
        .map(node -> node.getId() + node.getVersion()))
    .collect(Collectors.toSet());

方案2：保持原有序并发集合（NavigableSet） #

如果你需要和原有代码一致的有序且线程安全的集合（ConcurrentSkipListSet），可以指定集合类型：

NavigableSet<String> nodeNames = trees.parallelStream()
    .flatMap(tree -> tree.getNodes().stream()
        .map(node -> node.getId() + node.getVersion()))
    .collect(Collectors.toCollection(ConcurrentSkipListSet::new));

关键说明 #

• flatMap()：将每个Tree对应的节点名字符串流“平铺”为一个单一的全局流，让后续收集操作直接处理单个字符串元素，而非流对象。
• 并行流兼容性：Collectors.toSet()在并行流场景下会自动返回线程安全的Set实现；若需要有序集合，ConcurrentSkipListSet本身就是线程安全的有序集合，适合并行操作。
• 代码风格：新实现采用流的声明式风格，避免了手动维护并发集合和forEach的副作用，可读性与简洁性更优。

内容的提问来源于stack exchange，提问作者BugsOverflow