ExecutorService可扩展线程，然后对任务进行排队

Question

是否有一个ExecutorService实现，其行为类似具有以下特性的线程池？

1. 始终至少有X个活动线程。

相当标准的线程池行为。你可能会认为ThreadPoolExecator可以处理这个问题，但是

executorService = new ThreadPoolExecutor(
    2, 10, // min/max threads
    60, TimeUnit.SECONDS, // time of inactivity before scaling back
    new SynchronousQueue<Runnable>()); // task queue

如果提交了10个以上的任务，将引发异常。切换到LinkedBlockingQueue永远不会超过两个最小线程，除非您限制像new LinkedBlockingQueue这样的大小




Answer 1

这应该可以做到：

    ThreadPoolExecutor tpe = new ThreadPoolExecutor(1, maxPoolSize, 60L, TimeUnit.SECONDS,
            new SynchronousQueue<Runnable>());
    tpe.setRejectedExecutionHandler((
            Runnable r,
            ThreadPoolExecutor executor) -> {
        // this will block if the queue is full but not until the sun will rise in the west!
            try {
                if(!executor.getQueue().offer(r, 15, TimeUnit.MINUTES)){
                    throw new RejectedExecutionException("Will not wait infinitely for offer runnable to ThreadPoolExecutor");
                }
            } catch (InterruptedException e) {
                throw new RejectedExecutionException("Unable to put runnable to queue", e);
            }
        });

Answer 2

实际上，同步队列的大小基本上为零，因此，当您提交超过10个任务（最大池大小）时，拒绝策略会启动，任务会被拒绝。此外，对于每个提交的任务，它都会获得一个线程并加以利用。

当您使用大小为20的LinkedBlockingQueue时，如果已达到核心大小且没有空闲线程，它将对任务进行排队。除非队列已满，否则它们将继续排队，在这种情况下，它将创建一个用于新任务的新线程。当池大小达到最大值时，拒绝策略将用于任何新提交。

您希望每当提交任务时，核心（core-size）中的所有线程都很忙，您的任务应该获得一个新的线程，而不是在队列中等待，我认为这是不可能的。

Answer 3

不幸的是，答案是否定的。对于jre中的内容，你能做的最好的事情就是有效地没有Thread底板，只有天花板。这可以通过允许核心线程超时来实现。

ThreadPoolExecutor tpe = new ThreadPoolExecutor(10, 10, 60, TimeUnit.Seconds, new LinkedBlockingQueue<Runnable>());
tpe.allowCoreThreadTimeOut(true);

因为核心大小为10，所以在提交任务时会启动一个新线程，直到10个线程处于活动状态。之后，任务将在LinkedBlockingQueue中排队。如果一个线程处于非活动状态60秒，它将终止。

通过编写一个同时实现BlockingQueue和RejectedExecutionHandler的类，可以实现您想要的行为，该类在确定任务是否应添加到队列或被拒绝之前检查ThreadPoolExecutors的当前状态。