Java 8: Parallel FOR loop

Question

Я слышал, что Java 8 предоставляет множество утилит для параллельных вычислений. Поэтому мне интересно, что является самым простым способом для параллелирования данного цикла?

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

Читайте также: streams, все они новые ярости.

Обратите особенно пристальное внимание к биту о параллельности:

«Обработка элементах с явным для цикла по своей сути последовательного Streams облегчает параллельное выполнение, рефрейминг вычисления как трубопровод агрегированных операций, а не. как обязательные операции над каждым отдельным элементом. Все операции с потоками могут выполняться либо последовательно, либо параллельно ».

Итак, для повторения нет параллельных циклов, они по сути являются серийными. Однако потоки могут выполнять эту работу. Взгляните на следующий код:

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

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

Answer 2

Это было бы с помощью Stream:

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

Я подозреваю, что Collector может быть использован для большего эффекта здесь, так как вы используете параллельную коллекцию.

Answer 3

Более элегантный или функциональное решение будет только с помощью Коллекторы toMap или функции toConcurrentMap, которые не поддерживать другую динамическую переменную для ConcurrentHashMap, в следующем примере:

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

Примечание: 1. Эти функциональные интерфейсы (Server::getIdentifier or Server::fetchData) не позволяют исключить исключение для проверки, здесь 2. Чтобы получить полные преимущества параллельного потока, количество серверов будет большим и не будет задействовано ввода-вывода, чисто данных обработка в этих функциях ()

Пожалуйста, обратитесь к Коллекторы Javadoc на http://docs.oracle.com/javase/8/docs/api/java/util/stream/Collectors.html#toConcurrentMap

Answer 4

с помощью моего Parallel.For, ваш код может выглядеть следующим образом,

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

    Parallel.ForEach(servers, new LoopBody<Server>() 
    { 
     public void run(Server server) 
     { 
      String serverId = server.getIdentifier(); 
      String data = server.fetchData(); 

      serverData.put(serverId, data); 
     } 
    }); 
}