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

Question

我用例：

• 设置最小大小“N”对于这意味着“N”螺纹总是执行人启动后的可用线程池。
• 设置线程池的最大大小'M'。
• 当所有'M'线程忙时，传入任务应该排队。
• 基于空闲状态超时期满（M-N）线程。

我相信HttpClient后面的池管理器可能有类似的设置。我试图用ThreadPoolExecutor来实现它，但无法找到一种方法。可能吗？

这是一个测试的例子。

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); 

ThreadPoolExecutor

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

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

EDIT2：最大池大小只在队列满时启动。由于您使用的是无界队列，因此线程数不会超过2. Se链接位于下方。

rules-of-a-threadpoolexecutor-pool-size

认沽尺寸1，你会看到其中的差别。

new LinkedBlockingQueue<>(1)); 

编辑3：在您的例子改变startupExecutor.getCorePoolSize()与startupExecutor.getPoolSize()。