线程池执行器：任务正在排队并且没有提交

Question

我们有一个场景，提交给ThreadPoolExecitor的任务长时间运行。当线程池启动时，我们以核心池大小=5、最大池大小=20和队列大小为10启动它。在我们的应用程序中，大约有10个任务被提交。大多数时候，这些任务运行几分钟/小时，然后完成。但是有一种情况，所有5个任务都挂在I/O上。因此，我的核心池大小达到了最大值，但我的ThreadpoolExector队列未满。所以额外的5个任务从未有机会运行。请建议我们如何处理这种情况？在这种情况下，使用较小的队列是更好的选择吗？初始化threadPool时的最佳队列大小是多少？

同样关于挂起的任务，我们有没有办法从线程池中取出线程？在这种情况下，至少其他任务会有机会运行。

Answer 1

我认为另一种方法是根据队列中等待的任务数设置corePoolSize。可以使用setCorePoolSize控制corePoolSize。示例监视器线程可以控制threadPoolExecutor。您还可以改进此监视器以调整并行度。

    public class ExecutorMonitor extends Thread{

            ThreadPoolExecutor executor = null;
            int initialCorePoolSize;
            public ExecutorMonitor(ThreadPoolExecutor executor)
            {
                this.executor = executor;
                this.initialCorePoolSize = executor.getCorePoolSize();
            }
            @Override
            public void run()
            {
                while (true)
                {   
                    try {
                        Thread.sleep(5000);
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                    if (executor.getQueue().size() > 0)
                    {
                        if(executor.getActiveCount() < executor.getMaximumPoolSize())
                            executor.setCorePoolSize(executor.getCorePoolSize() + 1);
                    }
                    if (executor.getQueue().size() == 0)
                    {
                        if(executor.getCorePoolSize() > initialCorePoolSize)
                            executor.setCorePoolSize(executor.getCorePoolSize() -1);
                    }
                }
            }
        }

Answer 2

线程池执行器的Javadocs声明：

任何BlockingQueue都可用于传输和保存提交的任务。此队列的使用与池大小交互：

• 如果运行的线程少于corePoolSize，那么执行器总是倾向于添加新线程，而不是排队
• 如果corePoolSize或多个线程正在运行，执行者总是倾向于对请求排队，而不是添加新线程
• 如果请求无法排队，则会创建一个新线程，除非该线程超过maximumPoolSize，在这种情况下，任务将被拒绝

除非在5个线程“挂起”后超过队列大小，否则将无法获得更多线程。

真正的答案是：修复导致线程挂起的问题。否则，您将不得不实现一些方案，使用提交（）返回的Futures来取消线程，如果它们运行时间太长。

Answer 3

整体情况是这样的：

core pool size = 5,
max pool size = 20 and 
queue size of 10

提交10项任务。其中

1. I/O上挂起的5个任务=

因此，您的html" target="_blank">程序被挂起。

要了解有关ThreadPoolExecitor动态的更多信息，请在此处观看。该文档的注意点如下：

• 如果运行的线程少于corePoolSize，那么执行器总是倾向于添加新线程，而不是排队
• 如果corePoolSize或多个线程正在运行，执行者总是倾向于对请求排队，而不是添加新线程
• 如果请求无法排队，则会创建一个新线程，除非该线程超过maximumPoolSize，在这种情况下，任务将被拒绝

EDIT
如果您希望增加核心池大小，那么您可以使用setCorePoolSize（int corePoolSize）。如果您增加corepoolsize，那么如果需要，将启动新线程来执行任何排队的任务。