ThreadPoolExecutor配置

我想这是另一个答案，因为它对同一个问题有不同的解决方案。

您只能使用ThreadPoolExecutor和Semaphore。信号量将使用您希望在队列中允许的最大数量创建，并且在每个线程完成执行后，您将调用release（beforeExecute，即项目从队列中取出时）

    
      Semaphore semaphore = new Semaphore(1000);
ThreadPoolExecutor executor = new ThreadPoolExecutor(5,10,60,TimeUnit.SECONDS,new LinkedBlockingQueue()){
  protected void beforeExecute(Runnable r, Throwable t) {
     semaphore.release();
  }
}
public void doSubmit(Runnable r){
  sempahore.acquire();
  executor.submit(r);
}
</code>
  

只要队列长度太长，您就可以让生产者暂停。

这样的事情将等待任务队列的大小限制为MAX_LEN。

    
      ExecutorService service =
Queue workQ = // queue of service.
BufferedReader br =
String line;
while((line = br.readline()) != null) {
    service.submit(new ProcessLineRunnable(line));
    while(workQ.size() > MAX_LEN) Thread.sleep(1);
}
</code>
  

如果单个线程正在发出所有请求，那么无限制队列将根据您的喜好进行阻塞，而不会产生队列增长的负面影响。

如果多个线程发出请求，那么具有调用者运行策略的固定池应该可以按您的需要工作。池中的其余线程将由其他请求线程保持活动状态。

当当前正在使用所有线程时，ThreadPoolExecutor将创建更多线程。这意味着队列可以为空，但如果所有线程都在运行先前的任务，则新任务将创建一个新线程，直到达到最大值。

如果队列已满并且线程都已饱和，则ThreadPoolExecutor将实际拒绝该任务并抛出一个

RejectedExecutionException

。因此，使用BlockingQueue实际上不会产生预期的结果。

如果要限制当前队列中的任务数，可以使用ExecutorCompletionService和后备队列。

    
      //core 5 max 10 with 60 second idle time
ThreadPoolExecutor executor = new ThreadPoolExecutor(5,10,60,TimeUnit.SECONDS,new LinkedBlockingQueue());
ExecutorCompletionService completionService = new ExecutorCompletionService(executor);
private final static int MAX_IN_QUEUE = 1000; 
public void doSubmit(Runnable r){
    while(executor.getQueue().size() >= MAX_IN_QUEUE)
       completionService.poll(100,TimeUnit.MILLISECONDS);
    completionService.submit(r);
}
</code>