任务被拒绝由于最大池大小在ThreadPoolExecator

Question

应用程序已配置Zuul和Eureka将请求路由到后端服务，在我们进行负载测试之前，一切正常。

我开始在负载测试环境中执行10个并发请求，在zuul gateway中出现转发错误，原因是线程池无法为未来的任务分配线程，并拒绝任务，错误如下。

Caused by: java.util.concurrent.RejectedExecutionException: Task 
java.util.concurrent.FutureTask@70fe89b5 rejected from 
java.util.concurrent.ThreadPoolExecutor@25df1748[Running, pool size = 10, 
active threads = 10, queued tasks = 0, completed tasks = 1502]

我的奇迹；在上面的原因中，我看到池大小只有10个，而10个线程是buzy，很实用，因为我连续触发了10个请求。

但是我的corepoolsize应该比我在这里遇到的计数10大得多。是什么导致我的应用程序限制在10个池大小，我可以在我的应用程序中增加corepoolsize和maxpoolsize吗？

Answer 1

问题是你在使用哪个线程池？您可以在Java中定义各种ExecutorServices，例如为未知数量的线程定义缓存线程池，这将解决您的问题（我的一个项目的示例代码）：

ExecutorService pool = Executors.newCachedThreadPool();
    for(FluentCreate create: creates) {
        pool.execute(()->{
            try {
                create.execute();
            } catch (JiraException | IOException | ParseException | RestException | URISyntaxException e) {
                e.printStackTrace();
            }
        });
    }
pool.shutdown();
pool.awaitTermination(Long.MAX_VALUE, TimeUnit.MILLISECONDS);

如果你能够预测任务的数量，你可以使用固定的线程池。

Executors.newFixedThreadPool(3);

Answer 2

根据javadocs，ThreadPoolExecutor可能会出于以下几个原因引发RejectedExecutionException：

>

如果请求不能排队，并且不能创建另一个池线程，因为这将超过maxPoolsize。

如果已对执行器调用了shutdown（）方法。

现在你说你正在使用“默认”Java执行器，但有点不清楚你的意思。（如果你告诉我们你是如何获得和使用这个执行器的，就更容易理解你的问题了！）

但底线是池大小不太可能是您拒绝任务的原因。如果所有工作人员都很忙，任务应该排队。

但是我看到游泳池只有10个，这在现实生活中是不行的

在许多现实生活场景中，10个池的大小是可以接受的。但是，如果它不适合您的方案，则应该考虑创建具有较大（或较小）池的执行器。