Java 8：并行FOR循环

Question

我听说Java8提供了很多关于并发计算的实用程序。因此，我想知道并行给定for循环的最简单方法是什么？

public static void main(String[] args)
{
    Set<Server> servers = getServers();
    Map<String, String> serverData = new ConcurrentHashMap<>();

    for (Server server : servers)
    {
        String serverId = server.getIdentifier(); 
        String data = server.fetchData();

        serverData.put(serverId, data);
    }
}

Answer 1

更优雅或功能更强大的解决方案将只使用收集器toMap或toConcurrentMap函数，这样可以避免为ConcurrentHashMap维护另一个有状态变量，如下例所示：

final Set<Server> servers = getServers();
Map<String, String> serverData = servers.parallelStream().collect(
    toConcurrentMap(Server::getIdentifier, Server::fetchData));

注意：1.那些功能接口（Server::getIdfier或Server::fetchData）不允许抛出检查异常，2.为了获得并行流的全部好处，服务器的数量会很大，并且不涉及I/O，这些功能中纯粹是数据处理（getIdfier， fetchData）

请参阅收集器javadochttp://docs.oracle.com/javase/8/docs/api/java/util/stream/Collectors.html#toConcurrentMap

Answer 2

这将使用流：

servers.parallelStream().forEach(server -> {
    serverData.put(server.getIdentifier(), server.fetchData());
});

我怀疑Collector可以在这里发挥更大的作用，因为您使用并发集合。

Answer 3

阅读流，它们是最新流行的。

尤其要密切注意有关并行性的位：

具有显式for循环的处理元素本质上是串行的。流通过将计算重新构造为聚合操作的管道，而不是每个元素上的强制操作，来促进并行执行。所有流操作都可以串行或并行执行

所以总结一下，没有并行的for循环，它们本质上是串行的。但是流可以完成这项工作。看看下面的代码：

    Set<Server> servers = getServers();
    Map<String, String> serverData = new ConcurrentHashMap<>();

    servers.parallelStream().forEach((server) -> {
        serverData.put(server.getIdentifier(), server.fetchData());
    });