自定义scheduledExecutorService

### 如何自定义配置和使用 ScheduledExecutorService #### 创建定制化的 ScheduledExecutorService 实例 为了创建一个具有特定配置的 `ScheduledExecutorService`，可以通过扩展 `ScheduledThreadPoolExecutor` 类来自定义线程池的行为。这允许更细粒度地控制诸如核心线程数、最大线程数以及拒绝策略等参数。 ```java import java.util.concurrent.*; public class CustomScheduledExecutor { private final ScheduledThreadPoolExecutor executor; public CustomScheduledExecutor(int corePoolSize) { ThreadFactory threadFactory = new ThreadFactoryBuilder() .setNameFormat("custom-scheduled-pool-%d") .build(); RejectedExecutionHandler handler = new ThreadPoolExecutor.CallerRunsPolicy(); this.executor = new ScheduledThreadPoolExecutor(corePoolSize, threadFactory); executor.setRemoveOnCancelPolicy(true); // 取消的任务自动移除 executor.setExecuteExistingDelayedTasksAfterShutdownPolicy(false); // 关闭时不执行延迟任务 executor.setRejectedExecutionHandler(handler); // 设置拒绝策略 } public void schedule(Runnable command, long delay, TimeUnit unit) { executor.schedule(command, delay, unit); } } ``` 上述代码展示了如何通过继承 `ScheduledThreadPoolExecutor` 来构建一个带有自定义属性的调度器实例[^1]。 #### 配置线程工厂与异常处理机制 在线程池初始化过程中指定了一个名为 `threadFactory` 的对象，它负责新工作线程的创建过程。这里采用了 Google Guava 库中的 `ThreadFactoryBuilder` 工具简化了命名规则设置；同时指定了当提交给线程池的任务无法被执行时应采取的动作——即调用者自行运行该任务(`CallerRunsPolicy`)。 #### 控制取消行为及关闭后的操作模式 设置了两个重要的布尔标志位： - `setRemoveOnCancelPolicy`: 如果设为 true，则被取消的任务将会立即从队列中删除； - `setExecuteExistingDelayedTasksAfterShutdownPolicy`: 设定 false 表示在调用了 shutdown 方法之后不再继续执行那些已经安排好但是还未启动的任务。 这两个选项有助于更好地管理资源释放流程，并确保应用程序能够干净利落地终止正在等待执行的任务列表[^3]。 #### 提交周期性或一次性任务 一旦拥有了经过适当调整过的 `CustomScheduledExecutor` 对象，就可以像平常一样向其中添加新的作业项了。无论是固定延时还是重复触发的任务都可以轻松实现。 ```java // 定义要执行的任务逻辑 Runnable task = () -> System.out.println("Executing scheduled task"); // 构建并获取自定义的 ScheduledExecutorService CustomScheduledExecutor customScheduler = new CustomScheduledExecutor(2); // 执行一次性的定时任务，在5秒后执行 customScheduler.schedule(task, 5, TimeUnit.SECONDS); ``` 以上就是关于如何基于 Java 并发包内建的支持来自定义化 `ScheduledExecutorService` 的介绍[^4]。