检测 CompletableFuture 链中的超时

如何解决检测 CompletableFuture 链中的超时

是否有任何可能的安全方法来检测 CompletableFuture 链中的超时？

O someValue = CompletableFuture.supplyAsync(() -> {
                ...
                // API Call
                ...
            }).thenApply(o -> {
                ...
            }).thenApply(o -> {
                // If the chain has timed out,I still have 'o' ready here
                // So at least cache it here,so it's available for the next request
                // Even though the current request will return with a 'null'
                ...
            }).get(10,TimeUnit.SECONDS);
// cache 'someValue'
return someValue;

它在没有超时的情况下成功完成，我可以使用“someValue”并用它做任何事情

如果超时，它会抛出一个 TimeoutException 并且我已经丢失了该值，即使它仍在后台处理

这个想法是，即使它超时并且由于线程中的 API 调用仍然在后台完成并返回响应，我可以使用该值，比如说，用于缓存

解决方法

至少在你展示的方式上不是。抛出异常时，即使 API 调用完成，您也将失去任何获得 API 调用结果的机会。您在这样的链中缓存的唯一机会类似于以下内容，这对超时 API 调用本身没有帮助

.thenApplyAsync(o -> {
    cache = o;
    // do something
}).thenApplyAsync(o -> {
    cache = o;
    // do something more
}).get(10,TimeUnit.SECONDS);

但是通读this给了我一个想法，如果您执行以下操作会怎样

SynchronousQueue<Result> q = new SynchronousQueue<>();
CompletableFuture.supplyAsync(() -> {
    // API call
}.thenAccept(result -> {
    cache.put(result);   // cache the value
    q.offer(result); // offer value to main thread,if still there
}
);

// Main thread waits 10 seconds for a value to be asynchronously offered into the queue
// In case of timeout,null is returned,but any operations done
// before q.offer(result) are still performed

return queue.poll(10,TimeUnit.SECONDS);

未在 10 秒内完成的 API 调用仍会被处理到缓存中，因为它被异步接受并且超时发生在主线程而不是 CompletableFuture 链中，即使原始请求不会得到结果（我想必须优雅地处理它）。