我需要在Java（java.util.concurrent）中实现一个线程池，该线程池在空闲时处于最小数量，在作业提交到其完成速度快于完成时会增长到一个上限（但永远不会超过上限）
，并且在完成所有作业且不再提交任何作业时，缩小到下限。

您将如何实现这样的目标？我想这将是一个相当普遍的使用场景，但是显然java.util.concurrent.Executors工厂方法只能创建固定大小的池，并且当提交许多作业时池会无限增长。本ThreadPoolExecutor类提供corePoolSize和maximumPoolSize参数，但它的文档似乎暗示只有这样才能不断有超过corePoolSize在同一时间线是采用有界作业队列，在这种情况下，如果你已经达到maximumPoolSize线程，你会得到工作您必须自己处理的拒绝？我想出了这个：

//pool creation
ExecutorService pool = new ThreadPoolExecutor(minSize, maxSize, 500, TimeUnit.MILLISECONDS,
    new ArrayBlockingQueue<Runnable>(minSize));
...

//submitting jobs
for (Runnable job : ...) {
    while (true) {
        try {
            pool.submit(job);
            System.out.println("Job " + job + ": submitted");
            break;
        } catch (RejectedExecutionException e) {
            // maxSize jobs executing concurrently atm.; re-submit new job after short wait
            System.out.println("Job " + job + ": rejected...");
            try {
                Thread.sleep(300);
            } catch (InterruptedException e1) {
            }
        }
    }
}

我在俯视什么吗？有一个更好的方法吗？另外，根据一个人的要求，上面的代码要等到至少（我认为）(total number of jobs) - maxSize工作完成后才能完成，这可能是有问题的。因此，如果您希望能够向池中提交任意数量的作业，并在不等待任何作业完成的情况下立即进行操作，那么我不知道如果没有专门的“作业汇总”线程来管理该作业，怎么办？保留所有已提交作业所需的无界队列。AFAICS，如果您对ThreadPoolExecutor本身使用无限制队列，则其线程数将永远不会超过corePoolSize。