如何用newWorkStealingPool()实现类似ScheduledExecutorService的持续任务执行？

嘿，我明白你的困惑——newWorkStealingPool()返回的是普通的ExecutorService，确实没有ScheduledExecutorService那样的定时调度方法，但我们完全可以通过两种方式实现每秒持续执行任务的需求，下面给你详细讲：

方案一：在任务内部实现循环与延迟 #

这种方式最简单直接，让你的任务自己处理重复执行的逻辑，把它提交到工作窃取池即可。工作窃取池的线程会在任务sleep的时候去处理其他待执行的任务，不会浪费资源。

示例代码：

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

public class WorkStealingScheduledTask {
    public static void main(String[] args) {
        // 创建工作窃取线程池
        ExecutorService workStealingPool = Executors.newWorkStealingPool();
        
        // 提交一个持续执行的任务
        workStealingPool.submit(() -> {
            while (!Thread.currentThread().isInterrupted()) {
                try {
                    // 这里写你的任务逻辑
                    System.out.println("任务执行中，时间：" + System.currentTimeMillis());
                    
                    // 等待1秒后再次执行
                    Thread.sleep(1000);
                } catch (InterruptedException e) {
                    // 捕获中断信号，优雅退出循环
                    Thread.currentThread().interrupt();
                    System.out.println("任务被中断，即将退出");
                }
            }
        });
        
        // 注意：实际应用中要记得在合适的时机关闭线程池
        // workStealingPool.shutdown();
    }
}

需要注意：如果你的任务执行时间超过1秒，那么两次任务的间隔会变成「任务执行时间 + 1秒」，如果需要严格的1秒间隔，建议用第二种方案。

方案二：结合ScheduledExecutorService与工作窃取池 #

这种方式把定时调度的逻辑交给ScheduledExecutorService，而实际的任务执行交给newWorkStealingPool()，这样既能保证严格的定时间隔，又能利用工作窃取池的并行处理能力。

示例代码：

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

public class ScheduledWorkStealingTask {
    public static void main(String[] args) {
        // 创建工作窃取线程池用于执行任务
        ExecutorService workStealingPool = Executors.newWorkStealingPool();
        // 创建定时调度线程池
        ScheduledExecutorService scheduler = Executors.newSingleThreadScheduledExecutor();
        
        // 每秒提交一次任务到工作窃取池
        scheduler.scheduleAtFixedRate(() -> {
            workStealingPool.submit(() -> {
                // 这里写你的任务逻辑
                System.out.println("任务执行中，时间：" + System.currentTimeMillis());
            });
        }, 0, 1, TimeUnit.SECONDS);
        
        // 实际应用中记得关闭线程池
        // scheduler.shutdown();
        // workStealingPool.shutdown();
    }
}

这个方案的优势是：即使任务执行时间超过1秒，调度器依然会每秒提交新的任务（如果用scheduleAtFixedRate），适合需要严格频率的场景；如果担心任务堆积，可以改用scheduleWithFixedDelay，它会在上一个任务执行完成后再等待1秒提交下一个。

为什么newWorkStealingPool没有定时方法？ #

newWorkStealingPool()本质是返回一个ForkJoinPool实例，它的设计初衷是处理大量短生命周期的并行任务（比如递归拆分的计算任务），而不是周期性的定时调度任务。所以JDK没有给它内置定时API，需要我们自己结合现有工具实现。

内容的提问来源于stack exchange，提问作者Soheil Pourbafrani