ExecutorService如何实现任务重试机制

要使用ExecutorService实现任务重试机制，你可以创建一个包装任务（wrapper task），在这个包装任务中执行实际的任务，并在任务失败时进行重试。以下是一个简单的示例：

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

public class RetryTaskExample {

    public static void main(String[] args) {
        ExecutorService executorService = Executors.newFixedThreadPool(2);

        Runnable task = () -> {
            System.out.println("执行任务");
            throw new RuntimeException("任务执行失败");
        };

        Runnable retryTask = () -> {
            int maxRetries = 3;
            int retryCount = 0;

            while (retryCount < maxRetries) {
                try {
                    task.run();
                    break; // 任务成功执行，跳出循环
                } catch (Exception e) {
                    retryCount++;
                    System.out.println("任务执行失败，重试次数：" + retryCount);

                    if (retryCount >= maxRetries) {
                        System.out.println("达到最大重试次数，放弃重试");
                    } else {
                        try {
                            TimeUnit.SECONDS.sleep(1); // 等待一段时间后重试
                        } catch (InterruptedException ie) {
                            Thread.currentThread().interrupt();
                        }
                    }
                }
            }
        };

        executorService.submit(retryTask);
        executorService.shutdown();
    }
}

在这个示例中，我们创建了一个名为task的任务，它会抛出一个异常来模拟任务执行失败。然后，我们创建了一个名为retryTask的包装任务，它会尝试执行task，并在任务失败时进行重试。我们将retryTask提交给ExecutorService来执行。

这个示例中的重试机制是同步的，这意味着在重试期间，线程会阻塞等待。如果你需要异步重试，可以考虑使用其他工具，如CompletableFuture或者第三方库（例如Resilience4j）。