如何为并行webservice请求配置线程池？

Question

我想同时向一个webservice发送webservice调用。最多应有20个并行请求等待webservice响应。任何其他请求都应该等待它们完成。

如果一个用户向我发送一个请求，这通常会导致向目标服务器发送5个并行请求。因此，我一次最多可以服务20/5=4个用户。其他人将不得不等待，这很好。或者被高负荷拒绝。

问题：我应该使用哪个线程池，以及如何配置它？

private ExecutorService asyncExecutor() {
    ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
    executor.setCorePoolSize(20);
    executor.setMaxPoolSize(20);
    executor.setQueueCapacity(100);
    executor.initialize();

    //return executor.getThreadPoolExecutor(); //I could as well use this. Which is better??
    return Executors.newFixedThreadPool(20, executor);
}

我读了上面的内容如下：主池可以向网络服务器发送20个并行请求（从而在parralel中立即为4个用户服务）。如果所有20个线程都很忙，并且有第五个用户进来，请求就会排队。

问题：

>

配置是否正确？

为什么我必须另外在Executors.newFixedThreadpool（）中设置nthread=20？设置poolsize有什么区别？

设置corePoolsize=20会有性能开销吗？我的意思是，这样池就不会收缩。但是我可能不会把它设置得更低（例如5），因为只有当队列耗尽时才会创建新线程。对吗？

Answer 1

调用执行器时。newFixedThreadPool（20，执行器） 您正在将之前设置的执行器作为ThreadFactory传递，因为ThreadPoolTaskExecutor实现ThreadFactory接口。

结果是一个ExecutorService，它以20个线程就绪、最多20个线程和一个无限的LinkedBlockingQueue开始，用于等待处理的任务（您可以在这里看到）https://docs.oracle.com/javase/7/docs/api/java/util/concurrent/Executors.html#newFixedThreadPool（int，java.util.concurrent.ThreadFactory））。

至于你的第一个和第二个问题，你可以省略遗嘱执行人。如果您想使用jdk类ThreadPoolExecutor，可以调用newFixedThreadPool（）并返回ThreadPoolTaskExecutor或调用getThreadPoolExecutor（）。

至于你的第三个问题——在启动时会有一个惩罚，因为jvm必须创建并运行20个线程，但我想这可以忽略不计。将corePoolSize设置为低于maximumPoolSize的值的一件事是，jvm将终止未分配的线程，这可以减少应用程序的内存占用。

至于何时在ExecutorService中创建新线程-当队列中有任务并且没有达到最大池大小时，在ExecutorService中创建线程。如果达到执行器中的最大池大小并且队列已满-执行器将为提交给它的每个新任务抛出拒绝执行异常，直到再次有空间容纳新任务。您可以通过实现自己的拒绝执行处理程序来更改这种行为。

Answer 2

我觉得

executor.setMaxPoolSize(20) 

可以通过构造函数覆盖最初设置的#个线程，在这种情况下似乎是多余的。这同样适用于setCorePoolSize。这只是为了动态控制。根据池的大小，一般可以考虑小定律。