来自ScheduledExecutorService的多个期货的异常处理

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

public class ExceptionHandlingExample {
    public static void main(String[] args) {
        ScheduledExecutorService executorService = Executors.newScheduledThreadPool(5);

        // 创建多个任务并提交给ScheduledExecutorService
        for (int i = 0; i < 5; i++) {
            final int taskId = i;
            executorService.scheduleAtFixedRate(() -> {
                try {
                    // 执行任务的代码
                    System.out.println("Task " + taskId + " is running.");
                    if (taskId == 3) {
                        throw new RuntimeException("Exception occurred in Task " + taskId);
                    }
                } catch (Exception e) {
                    // 异常处理代码
                    System.out.println("Exception occurred in Task " + taskId + ": " + e.getMessage());
                }
            }, 0, 1, TimeUnit.SECONDS);
        }

        // 关闭ScheduledExecutorService
        executorService.shutdown();
    }
}