CompletableFuture＃thenApplyが使用されている場合は、whenCompleteは呼び出されません。

Question

ScheduledExecutorService#scheduleAtFixedRateを使用して、リモートサーバー上でタスクをスケジュールし、完了をポーリングする次のコードがあります（my previous questionの結果）。タスクが完了すると、結果がダウンロードされます。 呼び出し元にFutureを返信して、ブロックする時期と時間を決定し、タスクをキャンセルするオプションを与えることができます。

クライアントがを返した場合、downloadメソッドで返された場合、whenCompleteブロックは実行されません。 thenApplyが削除された場合それは私が何かを誤解していることは明らかですFuture構成...私は何を変更する必要がありますか？同じノートで

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; 
} 

、私がしなければ：代わりに

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

whenCompleteの

return completionFuture.whenComplete(...) 

も実行されません。これは私にとって非常に直感的ではないようです。論理的には、がwhenCompleteで返されてはいけません。

EDIT：

は私が明示的にキャンセルをバック伝播するために自分のコードを変更しました。それは忌まわしいと読めないのですが、それは動作し、私はより良い方法を見つけることができませんでした：次のように

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

あなたの構造は次のとおりです。

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

ですからthenApply将来、元completionFutureオブジェクトをキャンセルする場合thenApplyステージに依存しないため、影響を受けません。ただし、thenApplyステージをチェーンしていない場合は、元のcompletionFutureインスタンスを戻しています。このステージをキャンセルすると、すべての従属ステージがキャンセルされ、whenCompleteアクションがすぐに実行されます。

しかし、thenApplyステージがキャンセルされた場合、pollRemoteServer(jobId).equals("COMPLETE")の条件が満たされると、ポーリングが停止しないため、completionFutureがまだ完了することがあります。しかし、我々はjobId = schedule(something)とpollRemoteServer(jobId)の関係を知らない。この条件は、ダウンロードをキャンセルした後成就することはできませんという方法でアプリケーションの状態が変化した場合、この未来は、完全な...

---

将来は「私が握るべきものである、あなたの最後の質問、については決してありませんか？実際には、CompletableFutureという便利な方法は、このようなチェーンを作成しやすくしますが、多くの場合、最も有用ではありません。あなたが線形の依存関係を持っているならば、コードブロック。 2つの独立したステージを連鎖させるあなたのモデルは正しいですが、取り消しはそれでは機能しませんが、リニアチェインでも機能しません。

ソースステージをキャンセルできるようにするには参照が必要ですが、従属ステージの結果を取得するには、そのステージへの参照も必要です。