Java线程池执行器[提交超过MaxPoolsize]

Question

我有一个应用程序，允许用户批量向图像添加水印。该应用程序将只使用一个线程，并且一次只能添加一个水印。

我希望用户能够更改一次运行的水印任务[线程]的数量：可能在设置中为[1-5]，并且我不能使用固定的ThreadPool，因为它具有固定的池大小。

我研究了如何使用线程池执行器（ThreadPoolExecutor）私有静态线程池执行器（ThreadPoolExecutor）=（ThreadPoolExecutor）执行器。newCachedThreadPool（）

现在，当我尝试向最大池大小为3的执行者提交15个图像水印任务时，我得到以下例外：

Java语言util。同时发生的RejectedExecutionException：任务com。黑暗心理。zeondownloader。应用程序。主要的摄影工具。水印。BulkWatermarkTask$$Lambda$710/1861585081@1e2d8ad4从java拒绝。util。同时发生的ThreadPoolExecutor@24d02747[正在运行，池大小=3，活动线程=3，排队任务=0，已完成任务=0]

我希望ThreadPoolExecutor具有与fixedThreadPool相同的行为，在fixedThreadPool中，我可以拥有10个池大小，并且仍然可以提交任意多个任务，但我没有。我该怎么做呢？

Answer 1

查看JavaDoc会发现，这种行为是有意的。

当execute方法（java.lang.Runnable）中提交的新任务被关闭时，以及当executer对最大线程和工作队列容量使用有限边界且已饱和时，将拒绝这些任务。

因此，在您的情况下，您的队列似乎已满或不接受任何新项目。我还没有看到您实际上是如何创建ThreadPoolExecitor的，但我猜，您需要在构造函数中指定一个足够的BlockingQueue。

编辑：这可能会发生，因为Executors.newCachedThreadPool（）是无界的，如果没有可用的缓存线程，每次都会创建一个新线程。然而，设置最大池大小会干扰此操作，并且任务会通过Reject tedExecutionHandler被拒绝。

我目前无法再现该场景，但您可能可以将活动的AbortPolicy更改为ThreadPoolExecutor。CallerRunPolicy通过setRejectedExecutionHandler（ThreadPoolExecutor.CallerRunPolicy）调用。这将导致调用线程执行新任务，而不是引发异常。