ThreadPoolExecutor限制线程数

Question

我正在尝试创建一个具有一定数量线程的ThreadPoolExector，但同时，我想控制池队列的大小。所以我使用完整的构造函数创建了执行器：

 BlockingQueue<Runnable> pq =
     new ArrayBlockingQueue<Runnable>(MAX_THREADPOOL_SIZE);
 ThreadPoolExecutor threadPoolExecutor =
     new ThreadPoolExecutor(threadSize, threadSize, THREAD_IDLE_WAIT,
          TimeUnit.SECONDS, pq);

然而，这给了我一个非法辩论例外。如果我将构造函数更改为

new ThreadPoolExecutor(threadSize, **threadSize+1**, THREAD_IDLE_WAIT,
     TimeUnit.SECONDS, pq);

它起作用了。如果我希望理想的线程数和最大线程数相同，为什么它不起作用呢。

Answer 1

对恒定数量的线程使用工厂方法。

http://docs.oracle.com/javase/6/docs/api/java/util/concurrent/Executors.html#newFixedThreadPool（内景）

然后根据需要设置超时。

ThreadPoolExecutor exec = (ThreadPoolExecutor)Executors.newFixedThreadPool(threadSize);
exec.setKeepAliveTime(THREAD_IDLE_WAIT, TimeUnit.SECONDS);

Answer 2

我看不出你的初始代码为什么会抛出。如果您将来提供完整的例外情况，我们可以提供更具体的帮助。

需要记住的一件事是，一旦队列已满，使用有界阻塞队列将引发异常。这很少是你所期望的。如果查看我对以下问题的回答，您将看到需要配置拒绝执行处理程序（RejectedExecutionHandler）：

如果ThreadPoolExecutor命令需要处理的数据太多，如何使其等待？

要从那里进行复制，需要执行以下操作：

final BlockingQueue queue = new ArrayBlockingQueue<Runnable>(200);
ThreadPoolExecutor threadPool = new ThreadPoolExecutor(nThreads, nThreads,
           0L, TimeUnit.MILLISECONDS, queue);
// by default (unfortunately) the ThreadPoolExecutor will throw an exception
// when you submit the 201st job, to have it block you do:
threadPool.setRejectedExecutionHandler(new RejectedExecutionHandler() {
   public void rejectedExecution(Runnable r, ThreadPoolExecutor executor) {
      // this will block if the queue is full
      executor.getQueue().put(r);
   }
});

最后，如果最大线程大小大于核心线程大小，则必须意识到队列将在分配超过核心大小的任何其他线程之前填满。奇怪但真实。

Answer 3

来自javadoc：如果corePoolSize或keepAliveTime小于零，或者如果maximumPoolSize小于或等于零，或者如果corePoolSize大于maximumPoolSize。所以他们也可以是平等的。我也尝试过用相同的价值观进行构建，它很有效。也许源代码可以帮助您找出问题所在：

if (corePoolSize < 0 ||
    maximumPoolSize <= 0 ||
    maximumPoolSize < corePoolSize ||
    keepAliveTime < 0)
    throw new IllegalArgumentException();