Warum Lambda innerhalb der Karte nicht läuft?

Question

Ich versuche, Nebenläufigkeit und Lambdas in Java 8 zu lernen. Aber mein Code ist nicht in Lambda-Block in Karte eingeben.

List<Book> bookList = new ArrayList<Book>(); 
    isbnList 
    .stream() 
    .map(isbn -> (CompletableFuture.supplyAsync(() -> { 
     try { 
      List<String> pageContents = getUrlContents(webLink + isbn); 
      return new Book(
       parseBookTitle(pageContents), 
       isbn, 
       parseRank(pageContents) 
      ); 
     } catch (IOException ex) { 
      return null; 
     } 
    })).thenApply(a -> bookList.add(a)) 
    ); 

Während des Debuggens wird der Code bei .map line beendet und ich bekomme eine leere Buchliste. Sequenzieller Code für dasselbe gibt mir das richtige Ergebnis.

Answer 1

Eine Stream-Pipeline ist faul. Ohne eine Terminaloperation wird Ihre Stream-Pipeline nicht einmal ausgeführt. Stream.map ist eine Zwischenoperation, so dass es keine Pipelineausführung auslöst.

Nun könnte man einen forEach Schritt mit dem Lambda-Ausdruck cf -> cf.join() zum Verbinden auf Ihren erstellt CompletableFuture Instanzen für Ihre Pipeline hinzufügen, für jede Ihres Asynchron-Futures zu vervollständigen ausgeführt und warten wird. Wenn Sie so vorgehen, wird der ganze Zweck der Verwendung von asynchronen Futures zunichte gemacht, weil Sie sie sequentiell abliefern und auf den Abschluss jedes einzelnen warten, bevor Sie den nächsten einreichen.

Noch besser wäre es, könnten Sie Ihren Stream zu einem parallel Strom zu konvertieren, verwenden map mit Ihrem Körper Asynchron-Lambda direkt durch den CompletableFuture.supplyAsync Teil zu entfernen und mit collect für einen ähnlichen Effekt ohne die zusätzliche Unordnung zu sammeln.

List<Book> bookList = isbnList.parallelStream() 
    .map(isbn -> { 
     try { 
      List<String> pageContents = getUrlContents(webLink + isbn); 
      return new Book(
       parseBookTitle(pageContents), 
       isbn, 
       parseRank(pageContents) 
      ); 
     } catch (IOException ex) { 
      throw new RuntimeException(ex); 
     } 
    }).collect(Collectors.toList()); 

Weiterführende Literatur: Stream operations and pipelines im Stream API Javadoc.