在 ScheduledThreadPoolExecutor Java 中停止一个 sheduleAtFixedRate 任务

Question

假设我有这个臃肿的例子。 我期望发生的是在控制台中获得几个数字大约 3 次，然后我期望打印“任务已停止”行，然后我就不会再得到数字了。

所以我想停止执行任务。到目前为止，我已经尝试cancel(true) 未来，executor.shutdownNow)( 和executor.shutdown() 执行者，但这些都不会导致我上面描述的行为。我错过了什么吗？有没有办法取消这个任务？

        ScheduledThreadPoolExecutor executor = new ScheduledThreadPoolExecutor(1);
        executor.setRemoveOnCancelPolicy(true);
        final int rareNumber = 302330233;
        ScheduledFuture<?> future = executor.scheduleAtFixedRate(() -> {
            int x = 0;
            while (true) {
                x++;
                if(x % rareNumber == 0) {
                    System.out.println(x);
                }
            }
        }, 1, 2, TimeUnit.SECONDS);
        Thread.sleep(3_000);
        // I'd like to stop a task here.
        System.out.println("The task is stopped");

Answer 1

正确的方法是executor.shutdownNow()。这会导致线程被中断。

但是你的线程当时没有等待/休眠，所以你没有得到IterruptedException所以你需要检查Thread.intrrupted()标志：

ScheduledThreadPoolExecutor executor = new ScheduledThreadPoolExecutor(1);
    executor.setRemoveOnCancelPolicy(true);
    final int rareNumber = 302330233;
    ScheduledFuture<?> future = executor.scheduleAtFixedRate(() -> {
        int x = 0;
        while (true) {
            x++;
            if(x % rareNumber == 0) {
                System.out.println(x);
            }

            if (Thread.interrupted()) {
                return;
            }
        }
    }, 1, 2, TimeUnit.SECONDS);
    Thread.sleep(3_000);

    executor.shutdownNow();
    // I'd like to stop a task here.
    System.out.println("The task is stopped");

Answer 2

首先，当您在一次执行中找到正确的数字时，您应该打破while 循环以完成该执行周期。

ScheduledFuture<?> future = executor.scheduleAtFixedRate(() -> {
    int x = 0;
    while (true) {
        x++;
        if(x % rareNumber == 0) {
            System.out.println(x);
            break;
        }
    }
}, 1, 2, TimeUnit.SECONDS);

那么你可以按如下方式取消future来停止固定速率调度器。

    Thread.sleep(3_000);
    // I'd like to stop a task here.
    future.cancel(true);
    System.out.println("The task is stopped");

Answer 3

您应该在代码中考虑以下几点：

• 您永远不会关闭您的池，并且该池中的线程不是守护线程，因此如果您创建您的 Pool ，主 JVM 进程将被阻止关闭 - 因此您应该关闭您的池。关闭池将中断正在处理任务的线程。 ExecutorService docs 中描述了如何做到这一点：

void shutdownAndAwaitTermination(ExecutorService pool) {
   pool.shutdown(); // Disable new tasks from being submitted
   try {
     // Wait a while for existing tasks to terminate
     if (!pool.awaitTermination(60, TimeUnit.SECONDS)) {
       pool.shutdownNow(); // Cancel currently executing tasks
       // Wait a while for tasks to respond to being cancelled
       if (!pool.awaitTermination(60, TimeUnit.SECONDS))
           System.err.println("Pool did not terminate");
     }
   } catch (InterruptedException ie) {
     // (Re-)Cancel if current thread also interrupted
     pool.shutdownNow();
     // Preserve interrupt status
     Thread.currentThread().interrupt();
   }
 }

• 如果你想让你的任务可以取消，有两种常见的方法：

  1. 在循环中检查Thread.currentThread().isInterrupted() 状态
  2. 如果你调用了一些阻塞的方法并且可以抛出InterruptedException你可以处理这个异常。线程中断时会抛出。

• 正如您设置的executor.setRemoveOnCancelPolicy(true);，如果线程被中断，则不会重新创建线程。如果您没有设置此标志 - 保留中断状态是个好主意，因为您不是这些线程的所有者，并且您不知道中断对它们意味着什么。但是你没有使用任何可以抛出InterruptedException的方法，所以没关系。