CompletableFuture # whenComplete không được gọi nếu sau đóApply được sử dụng

Question

Tôi có mã sau (kết quả từ my previous question) lên lịch tác vụ trên máy chủ từ xa và sau đó thăm dò để hoàn thành sử dụng ScheduledExecutorService#scheduleAtFixedRate. Khi tác vụ hoàn tất, nó sẽ tải xuống kết quả. Tôi muốn trả lại số Future cho người gọi để họ có thể quyết định thời gian và thời gian chặn và cung cấp cho họ tùy chọn hủy tác vụ.

Vấn đề của tôi là nếu khách hàng hủy bỏ Future được trả về theo phương pháp download, thì khối whenComplete không thực thi. Nếu tôi xóa thenApply. Rõ ràng là tôi hiểu nhầm điều gì đó về thành phần Future ... Tôi nên thay đổi điều gì?

public Future<Object> download(Something something) { 
    String jobId = schedule(something); 
    CompletableFuture<String> job = pollForCompletion(jobId); 
    return job.thenApply(this::downloadResult); 
} 

private CompletableFuture<String> pollForCompletion(String jobId) { 
    ScheduledExecutorService executor = Executors.newSingleThreadScheduledExecutor(); 
    CompletableFuture<String> completionFuture = new CompletableFuture<>(); 

    ScheduledFuture<?> checkFuture = executor.scheduleAtFixedRate(() -> {   
      if (pollRemoteServer(jobId).equals("COMPLETE")) { 
       completionFuture.complete(jobId); 
      } 
    }, 0, 10, TimeUnit.SECONDS); 
    completionFuture     
      .whenComplete((result, thrown) -> { 
       System.out.println("XXXXXXXXXXX"); //Never happens unless thenApply is removed 
       checkFuture.cancel(true); 
       executor.shutdown(); 
      }); 
    return completionFuture; 
} 

Cùng lưu ý, nếu tôi làm:

return completionFuture.whenComplete(...) 

thay vì

completionFuture.whenComplete(...); 
return completionFuture; 

whenComplete cũng không bao giờ được thực thi. Điều này có vẻ rất phản đối với tôi. Không nên hợp lý Future trả lại bởi whenComplete là một trong những tôi nên giữ?

EDIT:

tôi đã thay đổi mã của tôi để rõ ràng back-tuyên truyền việc hủy bỏ. Đó là đáng ghê tởm và không thể đọc được, nhưng nó hoạt động và tôi không thể tìm thấy một cách tốt hơn:

public Future<Object> download(Something something) throws ChartDataGenException, Exception { 
     String jobId = schedule(report); 
     CompletableFuture<String> job = pollForCompletion(jobId); 
     CompletableFuture<Object> resulting = job.thenApply(this::download); 
     resulting.whenComplete((result, thrown) -> { 
      if (resulting.isCancelled()) { //the check is not necessary, but communicates the intent better 
       job.cancel(true); 
      } 
     }); 
     return resulting; 
} 

Answer 1

cấu trúc của bạn là như sau:

  ┌──────────────────┐ 
      │ completionFuture | 
      └──────────────────┘ 
      ↓    ↓ 
    ┌──────────────┐  ┌───────────┐ 
    │ whenComplete |  │ thenApply | 
    └──────────────┘  └───────────┘ 

Vì vậy, khi bạn hủy tương lai thenApply, các completionFuture đối tượng ban đầu vẫn không bị ảnh hưởng vì nó không phụ thuộc vào giai đoạn thenApply. Tuy nhiên, nếu bạn không kết nối giai đoạn thenApply, bạn sẽ trả về phiên bản completionFuture gốc và hủy giai đoạn này sẽ hủy bỏ tất cả các giai đoạn phụ thuộc, khiến hành động whenComplete được thực hiện ngay lập tức.

Nhưng khi giai đoạn thenApply bị hủy, completionFuture vẫn có thể được hoàn thành khi điều kiện pollRemoteServer(jobId).equals("COMPLETE") được hoàn thành, vì cuộc thăm dò đó không dừng lại. Nhưng chúng tôi không biết mối quan hệ của jobId = schedule(something) và pollRemoteServer(jobId). Nếu ứng dụng của bạn thay đổi trạng thái trong một cách mà tình trạng này có thể không bao giờ được hoàn thành sau khi huỷ một tải về, tương lai này sẽ không bao giờ hoàn chỉnh ...

---

Về câu hỏi cuối cùng của bạn, mà tương lai là “một trong những tôi nên giữ cho? ", Không có yêu cầu phải có một chuỗi tương lai tuyến tính, trên thực tế, trong khi các phương pháp tiện lợi của CompletableFuture giúp dễ dàng tạo chuỗi như vậy, thường xuyên hơn, đó là điều hữu ích nhất để làm, vì bạn chỉ cần viết khối mã, nếu bạn có một phụ thuộc tuyến tính. Mô hình chuỗi hai giai đoạn độc lập của bạn là đúng, nhưng việc hủy không hoạt động thông qua nó, nhưng nó cũng không hoạt động thông qua một chuỗi tuyến tính.

Nếu bạn muốn có thể hủy giai đoạn nguồn, bạn cần tham chiếu đến giai đoạn nguồn, nhưng nếu bạn muốn có được kết quả của giai đoạn phụ thuộc, bạn cũng sẽ cần tham chiếu đến giai đoạn đó.