如何创建一个ThreadPoolExecutor，根据需要创建线程并在适用时使其过期？

Question

我的用例：

• 为线程池设置最小大小“N”，这意味着“N”个线程在执行器启动后始终可用

我相信HttpClient背后的池管理器也可能有类似的设置。我试图实现它使用ThreadPoolExec导师，但无法找到一种方法。有可能吗？

下面是一个要测试的示例。

public class ExecutorExample {

    public static void main(String[] args) throws InterruptedException {
        int minPoolSize = 2;
        int maxPoolSize = 10;
        int ttlMillis = 100;
        ThreadPoolExecutor startupExecutor = new ThreadPoolExecutor(minPoolSize, 
                maxPoolSize, // surprisingly this is not obeyed.
                ttlMillis, 
                TimeUnit.MILLISECONDS, 
                new LinkedBlockingQueue<Runnable>());

        for (int i = 0; i < 20; i++) {
            System.out.println(Thread.currentThread().getName() + ":" + startupExecutor.getCorePoolSize());
            startupExecutor.execute(new MyRunnable(i));
        }

        for (int i = 0; i < 20; i++) {
            Thread.sleep(1000);
            System.out.println(Thread.currentThread().getName() + ":" + startupExecutor.getCorePoolSize());
        }
    }

}

class MyRunnable implements Runnable {

    int n;

    public MyRunnable(int n) {
        this.n = n;
    }

    @Override
    public void run() {
        try {
            Thread.sleep(2000);
            System.out.println(Thread.currentThread().getName() + ":" + n);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }

    }

}

Answer 1

这个怎么样：

        ThreadPoolExecutor executor = new ThreadPoolExecutor(corePoolSize, maximumPoolSize, keepAliveTime, unit, workQueue);

线程池

编辑：通常我使用的队列是有界阻塞队列。

BlockingQueue<Runnable> workQueue = new ArrayBlockingQueue(queueCapacity, true);

EDIT2:最大池大小仅在队列已满时生效。由于您使用的是无界队列，因此线程数不会超过2。请点击下面的链接。

线程池执行器池大小规则

放上1号，你会看到区别。

new LinkedBlockingQueue<>(1));

编辑3：在您的示例中，更改startupExecutor。getCorePoolSize（）和startupExecutor。getPoolSize（）。