在java8中如何实现异步重试机制？

CompletableFuture<String> future = CompletableFuture.supplyAsync(() -> {
    // 异步任务的逻辑
    return "result";
});

int maxRetries = 3; // 最大重试次数
int retryInterval = 1000; // 重试间隔时间（毫秒）

CompletableFuture<String> retryFuture = future.thenComposeAsync(result -> {
    CompletableFuture<String> retry = new CompletableFuture<>();
    AtomicInteger retryCount = new AtomicInteger(0);

    // 定义重试逻辑
    BiConsumer<String, Throwable> retryLogic = (res, ex) -> {
        if (ex != null && retryCount.getAndIncrement() < maxRetries) {
            try {
                Thread.sleep(retryInterval);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            CompletableFuture.supplyAsync(() -> {
                // 异步任务的逻辑
                return "result";
            }).whenComplete(retryLogic);
        } else {
            if (ex != null) {
                retry.completeExceptionally(ex);
            } else {
                retry.complete(res);
            }
        }
    };

    retryLogic.accept(result, null);
    return retry;
});

retryFuture.whenComplete((result, ex) -> {
    if (ex != null) {
        // 异步任务执行失败
        System.out.println("Async task failed: " + ex.getMessage());
    } else {
        // 异步任务执行成功
        System.out.println("Async task succeeded: " + result);
    }
});