ThreadPoolExecitor在低负载时不收缩

Question

在我的程序中，大多数时间任务很少提交给执行者，但它们并没有完全停止。当一次提交多个任务时，会出现周期性突发。

即使设置了allowCoreThreadTimeOut，并且在大多数情况下只有一个线程就足够了，但冗余的执行器线程不会停止。

这是因为执行器阻塞队列的公平性：当多个线程等待它时，所有线程都有同等的机会获得一个任务，并且它们的空闲时间不会显著增长。

有解决方法吗？例如，在多个等待线程的情况下，一个队列会在id最低的线程中返回？

public class ShrinkTPE {

    public static void main(final String[] args) throws Exception {
        final ThreadPoolExecutor executor = (ThreadPoolExecutor) Executors
                .newFixedThreadPool(NTHREADS);
        executor.setKeepAliveTime(ALIVE_TIME, TimeUnit.SECONDS);
        executor.allowCoreThreadTimeOut(true);

        // thread alive time is 10s
        // load all threads with tasks at start and every 12s
        // also submit one task each second
        for (int i = 0;; i++) {
            int j = 0;
            do {
                if (false && !mostThreadsUnused(i))
                    break;
                final int i2 = i, j2 = j;
                executor.submit(new Callable<Void>() {
                    @Override
                    public Void call() throws Exception {
                        System.out.println(""
                                + Thread.currentThread().getName() + " " + i2
                                + " " + j2);
                        Thread.sleep(300);
                        return null;
                    }
                });
            } while (mostThreadsUnused(i) && ++j < NTHREADS);
            Thread.sleep(1000);
            System.out.println();
        }
    }

    private static boolean mostThreadsUnused(final int i) {
        return i % (ALIVE_TIME + 2) == 0;
    }

    private static final int NTHREADS = 5;

    private static final int ALIVE_TIME = 10;
}

Answer 1

newCachedThreadPool的官方JDK实现如下所示。如果您想设置最大线程池大小或自定义保留AliveTime或使用不同的队列，您可以简单地直接调用该构造函数。

public static ExecutorService newCachedThreadPool() {
    return new ThreadPoolExecutor(0, Integer.MAX_VALUE,
                                  60L, TimeUnit.SECONDS,
                                  new SynchronousQueue<Runnable>());
}

Answer 2

final ThreadPoolExecutor executor = (ThreadPoolExecutor) Executors.newFixedThreadPool(N_THREAD);

您使用的是固定线程池，这意味着，该池将始终有N_THREAD线程数。

使用不同的线程池，也许是CachedThreadPool？它会重用现有线程，但如果您向池中提交新任务，它会启动额外的线程，并且不会有空闲线程。

空闲线程在X个时间后死亡（默认为60秒空闲）