Java：SingleThreadScheduledExecutor & java.util.concurrent.RejectedExecutionException答案

【问题标题】：Java: SingleThreadScheduledExecutor & java.util.concurrent.RejectedExecutionExceptionJava：SingleThreadScheduledExecutor & java.util.concurrent.RejectedExecutionException
【发布时间】：2010-12-28 14:51:52
【问题描述】：

我有这个问题，我有

private ScheduledExecutorService executor =  
     Executors.newSingleThreadScheduledExecutor();

每 50 毫秒创建一次的任务：

executor.scheduleAtFixedRate(myTask, 0, 50, TimeUnit.MILLISECONDS);

myTask 有时需要一段时间才能完成（比如 2-3 秒左右），但 newSingleThreadScheduledExecutor 保证下一个计划的 myTask 将等到当前的完成。

但是，我有时会收到此错误：

执行：java.util.concurrent.RejectedExecutionException

我该怎么办？谢谢

【问题讨论】：

请更具体地说明您所说的“不时”是什么意思。只有在 ExecutorService 上调用 execute() 时才应引发该异常。
其实 RejectedExecutionException 是 executor.scheduleAtFixedRate() 可以抛出的
@Andrey，您需要向我们提供更多信息，从显示异常的堆栈跟踪开始。
@Jim，是的，我的意思是“在提交作业的那一刻”，而不是“不时”:)
是的，有时当我调用 scheduleAtFixedRate 时会抛出 RejectedExecutionException（不是总是，但我猜当我的 myTask 需要比以往更多的时间来完成时它开始抛出异常）。

标签： java multithreading exception concurrency executor

【解决方案1】：

考虑执行者在做什么。根据您的指示，它每 50 毫秒运行一个任务。假设这个任务的运行时间少于 50 毫秒，那么一切都很好。但是，每隔一段时间就需要 2-3 秒才能运行。发生这种情况时，执行器仍会尝试每 50 毫秒执行一次，但因为它只有一个线程，所以它不能，并拒绝那些在您的长时间运行的任务仍在进行时被触发的执行。这会导致您看到的异常。

您有两种选择来解决这个问题（假设您想坚持使用单个线程）：

使用scheduleWithFixedDelay 而不是scheduleAtFixedRate。如果您仔细阅读 javadoc，您会发现scheduleWithFixedDelay 将在完成一项任务和开始下一项任务之间等待 50 毫秒，因此它永远不会“重叠”，即使其中一项需要很长时间。相比之下，scheduleAtFixedRate 将尝试每 50 毫秒执行一次，而不管每次执行需要多长时间。
更改执行程序处理执行失败的方式。默认是记录一个异常，但你可以告诉它忽略它，例如。看一下java.util.concurrent.RejectedExecutionHandler的子类，例如DiscardPolicy，它只是默默地丢弃了无法运行的任务。您可以通过直接构造 ScheduledThreadPoolExecutor 并将处理程序传递给构造函数来使用它们，而不是使用 Executors 工厂类。

我怀疑选项 (1) 是您想要的。

【讨论】：

@skaffman：实际上这与您在 1 中所说的完全相反。:) javadoc：scheduleAtFixedRate：如果此任务的任何执行时间超过其周期，则后续执行可能会延迟开始，但是不会同时执行

【解决方案2】：

以下任一情况都会引发此异常：

您已关闭 Executor
已超出 Executor 的工作队列界限或最大线程数。

我认为后者正在发生。当您执行任务并且需要很长时间时，随后的计划任务将无法运行，因为池中没有足够的可用线程。

要么：

使用更大的池大小或使用 cachedThreadPool
将拒绝策略更改为例如使用 ThreadPoolExecutor.CallerRunsPolicy
创建一个单独的执行器来运行长期任务并从您的计划任务中运行这些任务。实际上，只要增加池大小，您就可以使用相同的 Executor 实例来执行此操作。

另见ThreadPoolExecutor javadoc

【讨论】：

在我的情况下如何使用cachedThreadPool？ executor.scheduleAtFixedRate(myTask, 0, 50, TimeUnit.MILLISECONDS);如何更改 ThreadPoolExecutor 拒绝策略？谢谢

【解决方案3】：

在 Java 7 中，它们都将等待第一次执行准备好，然后再开始下一次执行！

在这里查看：
http://download.java.net/jdk7/archive/b123/docs/api/java/util/concurrent/ScheduledThreadPoolExecutor.html

或在这里：
http://docs.oracle.com/javase/7/docs/api/java/util/concurrent/ScheduledThreadPoolExecutor.html

【讨论】：