取消在计划执行器服务中计划的任务使执行程序保持活动状态

Question

这已经困扰了我几个小时了。如果我安排一个任务在5秒内执行，然后立即取消该任务，我会期望“awaitTermination”方法立即返回，但它会在整个7秒（而不是5秒）内保持阻塞。

下面是一个 JUnit 5 测试用例，它在 Java 11 上重现了这个问题。

package dummy;

import org.junit.jupiter.api.DisplayName;

import org.junit.jupiter.api.Test;

import java.util.concurrent.Executors;

import java.util.concurrent.ScheduledExecutorService;

import java.util.concurrent.ScheduledFuture;

import java.util.concurrent.TimeUnit;

import java.util.concurrent.atomic.AtomicBoolean;

import static org.junit.jupiter.api.Assertions.assertFalse;

import static org.junit.jupiter.api.Assertions.fail;

class DummyTest {

  @Test

  @DisplayName("Cancelling task should work...")

  void cancel_task() throws InterruptedException {

    ScheduledExecutorService executorService = Executors.newSingleThreadScheduledExecutor();

    AtomicBoolean isExecuted = new AtomicBoolean(false);

    ScheduledFuture<?> scheduled = executorService.schedule(() -> isExecuted.set(true), 5, TimeUnit.SECONDS);

    scheduled.cancel(false);

    if (!executorService.awaitTermination(7, TimeUnit.SECONDS)) {

      fail("Didn't shut down within timeout"); // <-- Fails here

    }

    assertFalse(isExecuted.get(), "Task should be cancelled before executed");

  }

}

有什么想法吗？

Answer 1

您不会在执行器服务上调用 shutdown 或 shutdownNow，因此您可以永远等待。它永远不会终止。首先调用关闭，然后单元测试应该可以正常工作。scheduled.cancel(false);executorService.shutdown(); // This was missingif (!executorService.awaitTermination(7, TimeUnit.SECONDS)) {...等待终止“阻止所有任务在关闭请求后完成执行，或者发生超时，或者当前线程中断，以先发生者为准”（从评论中复制，感谢 ptomli）。