Java 8 parallelStream dla współbieżnej bazy danych/wywołania REST

Question

Tutaj używam strumienia Javaparallel do iterowania listy i wywoływania wywołania REST z każdym elementem listy jako danych wejściowych. Muszę dodać wszystkie wyniki wywołania REST do kolekcji, dla której używam ArrayList. Kod podany poniżej działa dobrze, z wyjątkiem tego, że niezwiązane z wątkami bezpieczeństwo tablicy ArrayList spowodowałoby niepoprawne wyniki, a dodanie wymaganej synchronizacji spowodowałoby rywalizację, podważając korzyść równoległości.

Czy ktoś może zaproponować mi odpowiedni sposób wykorzystania równoległego strumienia w mojej sprawie.

public void myMethod() { 
    List<List<String>> partitions = getInputData(); 
    final List<String> allResult = new ArrayList<String>(); 
    partitions.parallelStream().forEach(serverList -> callRestAPI(serverList, allResult); 
} 

private void callRestAPI(List<String> serverList, List<String> allResult) { 
    List<String> result = //Do a REST call. 
    allResult.addAll(result); 
} 

Answer 1

można zrobić operację z map zamiast forEach - które zagwarantuje bezpieczeństwo wątków (i jest odkurzacz z funkcjonalnego punktu widzenia programowania):

List<String> allResult = partitions.parallelStream() 
      .map(this::callRestAPI) 
      .flatMap(List::stream) //flattens the lists 
      .collect(toList()); 

A twój callRestAPI method:

private void callRestAPI(List<String> serverList) { 
    List<String> result = //Do a REST call. 
    return result; 
} 

Answer 2

Nie wahałbym się przed synchronizowaniem dostępu do twojego ArrayList. Biorąc pod uwagę, że uzyskujesz dostęp do usługi zdalnej przez Rest, podejrzewam, że koszt synchronizacji będzie wynosił bez znaczenia:. Zmierzyłbym efekt zanim poświęcisz czas na optymalizację.