Tiêu thụ Dịch vụ Nghỉ ngơi theo cách chức năng

Question

Vì vậy, tôi đã tò mò về cách mã sau sẽ được viết lại hiệu quả hơn với API luồng java8.

public static List<FlightInfo> getResults(String origin,List<String> destinations) { 

    final String uri = "https://api.searchflight.com/; 
    List<FlightInfo> results = new LinkedList<FlightInfo>(); 

    for(String destination:destinations) { 


      RestTemplate restTemplate = new RestTemplate(); 

      String params = getParams(origin,destination); 
      FlightInfo result = restTemplate.postForObject(uri+params,FlightInfo.class); 

      results.add(result); 
    } 

    return results; 

} 

Sau khi phương pháp này được thực hiện làm những gì mình đang làm và tôi nhận được danh sách các đối tượng FLightInfo, tôi đang chuyển đổi nó thành một dòng suối và sẽ được làm biến đổi khác nhau trên nó (nhóm bằng, vv). Bây giờ nó là khá apparant rằng đây là một hoạt động chạy dài. Hơn nữa nó thực sự kết hợp nhiều cuộc gọi còn lại với dịch vụ web, vì vậy tôi đã có hầu hết dữ liệu thu được khi tôi thực hiện cuộc gọi cuối cùng, nhưng tôi sẽ không bắt đầu xử lý nó trước khi toàn bộ phương thức trả về.

Có cách nào để làm tất cả điều đó một chút phản ứng hơn không? Tôi có thể trả về một dòng ngay lập tức và có các hoạt động trên luồng dữ liệu quá trình đó khi nó đi xuống đường ống hay đây là một chút quá nhiều để hỏi? Làm thế nào sẽ được thực hiện trong Java 8. Điều đó

Answer 1

Vâng tất cả phụ thuộc vào khi bạn cần kết quả. Nếu bạn muốn nó được tuần tự, điều này dưới đây vẫn là một cách phong nha như lười biếng của nó. Nhưng nó sẽ đun sôi tại một hoạt động đầu cuối (nói trong thời gian collect).

public static Stream<FlightInfo> getResults(String origin,List<String> destinations) { 
    final String uri = "https://api.searchflight.com/"; 
    return destinations.stream().map(destination -> { 
     RestTemplate restTemplate = new RestTemplate(); 
     String params = getParams(origin,destination); 
     FlightInfo result = restTemplate.postForObject(uri+params,FlightInfo.class); 
     return result; 
    })  
} 

Hoặc tôi sẽ làm điều đó với destinations.stream().parallel() nếu có thể. Đây là một kết quả hợp lý trong hầu hết các trường hợp. Nhưng nó vẫn sẽ không bắt đầu xử lý nó song song cho đến khi bạn gọi một hoạt động đầu cuối cho nó. Điều đó hoàn toàn có ý nghĩa.

Nhưng có vẻ với tôi rằng bạn mong muốn một loại người tiêu dùng sản xuất một thứ. Mà:

public static CompletableFuture<List<FlightInfo>> getResults(String origin,List<String> destinations) { 
    final String uri = "https://api.searchflight.com/"; 
    List<CompletableFuture<FlightInfo>> collect = destinations 
      .stream() 
      .map(destination -> CompletableFuture.supplyAsync(() -> { 
       RestTemplate restTemplate = new RestTemplate(); 
       String params = getParams(origin,destination); 
       FlightInfo result = restTemplate.postForObject(uri+params,FlightInfo.class); 
       return result;    
      })).collect(Collectors.toList()); 
    return sequence(collect);  //line-1 
} 

public static <T> CompletableFuture<List<T>> sequence(List<CompletableFuture<T>> com) { 
    return CompletableFuture.allOf(com.toArray(new CompletableFuture[com.size()])) 
      .thenApply(v -> com.stream() 
          .map(CompletableFuture::join) 
          .collect(Collectors.toList()) 
      ); 
} 

cho đơn giản, tại line-1 bạn chỉ có thể trở lại collect thay vì sequence(collect). Sau đó, bạn có thể lặp qua danh sách để tìm nạp từng giá trị.

Nhưng với sequence, bạn có một đối tượng CompletableFuture duy nhất cần lo lắng, sau đó bạn có thể kiểm tra các giá trị cùng một lúc nếu hoàn thành.