RetryExecutor :如何等待所有任务完成？

RetryExecutor是一个用于执行重试任务的工具类。它可以帮助我们在任务执行失败时自动进行重试，并且可以等待所有任务完成后再继续执行其他操作。

要等待所有任务完成，可以使用CountDownLatch来实现。CountDownLatch是Java中的一个同步工具类，它可以让一个或多个线程等待其他线程完成操作后再继续执行。

下面是一个使用RetryExecutor等待所有任务完成的示例代码：

import java.util.concurrent.CountDownLatch;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

public class RetryExecutorExample {
    public static void main(String[] args) throws InterruptedException {
        int taskCount = 5; // 任务数量

        // 创建RetryExecutor
        RetryExecutor retryExecutor = new RetryExecutor();

        // 创建CountDownLatch，初始计数为任务数量
        CountDownLatch latch = new CountDownLatch(taskCount);

        // 创建线程池
        ExecutorService executorService = Executors.newFixedThreadPool(taskCount);

        for (int i = 0; i < taskCount; i++) {
            final int taskId = i;
            executorService.submit(() -> {
                try {
                    // 执行任务
                    retryExecutor.execute(() -> {
                        // 任务逻辑
                        System.out.println("Task " + taskId + " is executing");
                        // 模拟任务执行失败的情况
                        if (taskId % 2 == 0) {
                            throw new RuntimeException("Task " + taskId + " failed");
                        }
                    });
                } catch (Exception e) {
                    e.printStackTrace();
                } finally {
                    // 任务完成，计数减一
                    latch.countDown();
                }
            });
        }

        // 等待所有任务完成
        latch.await();

        // 关闭线程池
        executorService.shutdown();

        System.out.println("All tasks completed");
    }
}

在上面的示例代码中，我们创建了一个RetryExecutor，并使用CountDownLatch来等待所有任务完成。每个任务都会被提交到线程池中执行，任务执行完成后会调用CountDownLatch的countDown()方法来减少计数。当所有任务都完成时，主线程会从await()方法中返回，然后可以继续执行其他操作。

这里推荐使用腾讯云的云函数SCF（Serverless Cloud Function）来执行任务。云函数是一种无服务器计算服务，可以帮助开发者更轻松地构建和运行各种应用程序和服务。腾讯云的云函数产品介绍和文档链接如下：