移交ScheduledThreadPoolExecutor

Question

我在理解ScheduledExecutorService/ScheduledThreadPoolExecutor的具体工作方式时遇到一些问题。我想进行以下设置：

1. 一个类，它设置ScheduledThreadPoolExecutor，在调度任务之前将RemoveOnCancelPolicy设置为true，并关闭ScheduledThreadPoolExecutor（因为我想在try-catch块中调用product函数）。TAK的处理应在第二类中完成，这就是为什么我想移交ScheduledThreadPoolExecutor

public class SetupExecutorService implements AutoCloseable {
    
    private final ScheduledThreadPoolExecutor executorService;
    private final Producer producer;

    public SetupExecutorService(Producer producer) {
        executorService = new ScheduledThreadPoolExecutor(1);
        this.producer = producer;
    }

    public void produce() {
        executorService.setRemoveOnCancelPolicy(true);
        producer.schedule(executorService);
    }
    
    @Override
    public void close() throws Exception {
        executorService.shutdown();
    }

}

public class Producer implements Runnable {

    public Producer(int pauseInMilliSec) {
        this.pauseInMilliSec = pauseInMilliSec;
    }

    @Override
    public void run() {
        System.out.println("calling run");
        ...
    }

    public void schedule(ScheduledExecutorService executorService) {
         executorService.scheduleAtFixedRate(this, 0, pauseInMilliSec, TimeUnit.MILLISECONDS);
    }

}

不幸的是，此设置不起作用。我不确定哪里出了问题，但是，如果我只是在Producer类中拉取executorService，一切都会按预期工作，并且任务会定期执行：

public class Producer implements Runnable {

    public Producer(int pauseInMilliSec) {
        this.pauseInMilliSec = pauseInMilliSec;
    }

    @Override
    public void run() {
        System.out.println("calling run");
        ...
    }

    public void schedule() {
         ScheduledThreadPoolExecutor executorService = new ScheduledThreadPoolExecutor(1);
         executorService.setRemoveOnCancelPolicy(true);
         executorService.scheduleAtFixedRate(this, 0, pauseInMilliSec, TimeUnit.MILLISECONDS);
    }

}

有人能告诉我错误在哪里吗？

非常感谢您的帮助：）

Answer 1

当您关闭执行器时，它将不再接受任何任务，只会耗尽当前队列中的挂起任务。在ScheduledExecutor的情况下，所有未来计划的任务都将被取消，并且不会触发。

换句话说，在第一个计划任务运行之前，您正在关闭执行程序，有效地取消了它。在第二种情况下，你没有关闭执行者——因此它起作用了。

如果在“已损坏”设置中删除关机，则其行为方式将与“已修复”版本相同。