Java 线程池中 newScheduledThreadPool 怎么使用
使用 executors.newscheduledthreadpool() 可以创建一个支持定时和周期性任务执行的线程池。核心做法是调用该工厂方法获取 scheduledexecutorservice 实例，然后使用 schedule() 执行单次延迟任务，或使用 scheduleatfixedrate() 和 schedulewithfixeddelay() 执行周期性任务。这些方法接受 runnable 或 callable 任务、延迟时间以及时间单位作为参数。
如何区分 scheduleAtFixedRate 与 scheduleWithFixedDelay
这两个方法都用于周期性任务，但计算周期的基准不同。scheduleAtFixedRate 以任务开始时间为基准，如果任务执行耗时超过间隔，下一次任务会立即启动；scheduleWithFixedDelay 以任务结束时间为基准，无论任务执行多久，结束后都会等待固定的延迟时间才启动下一次任务。
javascript-typescript-typescript-scaffold
下载
你是 TypeScript 项目架构专家，专注于脚手架搭建生产就绪的 Node.js 和前端应用。生成包含现代工具链（pnpm、Vite、Next.js）、类型
import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;
public class ScheduledPoolDemo {
public static void main(String[] args) {
ScheduledExecutorService scheduler = Executors.newScheduledThreadPool(2);
// 示例：每5秒执行一次，固定速率
scheduler.scheduleAtFixedRate(() -> {
System.out.println("Task A: Fixed Rate - " + System.currentTimeMillis());
try { Thread.sleep(2000); } catch (InterruptedException e) {}
}, 0, 5, TimeUnit.SECONDS);
// 示例：每5秒执行一次，固定延迟
scheduler.scheduleWithFixedDelay(() -> {
System.out.println("Task B: Fixed Delay - " + System.currentTimeMillis());
try { Thread.sleep(2000); } catch (InterruptedException e) {}
}, 0, 5, TimeUnit.SECONDS);
// 保持主线程运行以便观察输出
try { Thread.sleep(30000); } catch (InterruptedException e) {}
scheduler.shutdown();
}
}基于程序中某个输入、条件或结果的具体问题
当周期性任务中抛出未捕获的异常时，线程池的行为取决于具体方法。对于 scheduleAtFixedRate 和 scheduleWithFixedDelay，如果任务抛出异常，该特定任务的后续调度会被取消，但线程池本身不会关闭，其他任务仍可正常执行。这与 schedule 单次任务类似，异常会导致该次执行终止且不再重试。
立即学习“Java免费学习笔记（深入）”；
