ThreadPoolExecutor的corePoolSize和maximumPoolSize

按照JDK文档的描述，

• 如果池中的实际线程数小于corePoolSize,无论是否其中有空闲的线程，都会给新的任务产生新的线程
• 如果池中的线程数>corePoolSize and <maximumPoolSize,而又有空闲线程，就给新任务使用空闲线程，如没有空闲线程，则产生新线程
• 如果池中的线程数＝maximumPoolSize，则有空闲线程使用空闲线程，否则新任务放入workQueue。（线程的空闲只有在workQueue中不再有任务时才成立）

ThreadPoolExecutor中有方法setCorePoolSize()和setMaximumPoolSize来设置corePoolSize和maximumPoolSize的大小，

• 如果新值大于旧值，则对新任务新线程
• 如果新值小于旧值，则在有线程空闲时，减少池中的线程数

但是在实际应用中想实时修改池的线程数，得有一定的条件，特别是要减少线程数，

• 首先，如果提交的新任务太多，以至总是没有线程空闲下来，线程就不会减少
• 即使有线程空闲，也不一定能减少线程，这还同所使用的workQueue有关，还需要workQueue.remainingCapacity==0。在JDK所提供的所有BlockingQueue中，只有SynchronousQueue的remainingCapacity()能返回0。

而如果实际应用中需要使用ScheduledThreadPoolExecutor来安排任务，同时需要新安排的任务数又非常多，这时要即时动态线程池的大小，就几乎不可能了，因为ScheduledThreadPoolExecutor用的是LinkedBlockingQueue。这时可以按照JDK的方式实现一个自己的ScheduledThreadPoolExecutor，

首先，稍微修改一下JDK的ThreadPoolExecutor就能实现一个自己的ThreadPoolExecutor,

• 在setCorePoolSize方法中,去掉workQueue.remainingCapacity==0的条件
• 让ThreadPoolExecutor中的Worker的interruptIfIdle()方法给Worker设置一个标志，让这个Worker不再检查workQueue中还没有执行的任务，立即中止
• 还有就是修改一下ThreadPoolExecutor中实现的RejectedExecutionHandler，毕竟很多情况下都可以不需要它

有了自己ThreadPoolExecutor，就可以继承它来实现自己的ScheduledThreadPoolExecutor了（再原本照抄JDK的ScheduledThreadPoolExecutor的实现就可以了^_^）。

 

终于有了符合自己需要的ScheduledThreadPoolExecutor了，现在用它来每秒运行1000个任务，还需要每个小时改变并发任务数（50～200之间的随机值），至少要维持30天。

 

评论

2 楼 Sgr_pippo 2015-06-03  

mengjun004 写道

参考JDK文档，它的描述应该是这样的：
1） 如果空闲的线程数小于corePoolSize，创建新线程
2） 如果提交的线程数大于corePoolSize并且小于maximumPoolSize，只会有等于corePoolSize的线程数被创建，然后将打印任务提交到队列中，直到队列满了，才会创建小于等于maximumPoolSize的线程，然后将多余的任务处理掉。

请牛人解析下，谢谢！

1) 假设初始设置线程池可容纳2个线程(corePoolSize = 2)，这个可以理解为“按照正常情况我就该跑两个线程，这是我的责任”。所以当池中还不足两个线程的时候，有新任务来到，不会考察有没有空闲线程，而是直接创建一个新线程

2)还是假设corePoolSize = 2， maximumPoolSize无限大， 且目前提交了3个任务，任务队列容量为1；那么执行其中两个，剩下的一个先放在任务队列中，直到前面这两个任务空出1个线程，再由这个空出的线程去执行这第三个。

3)还是上面的情况，如果提交了4个任务。相当于3个任务后，任务队列都满了。此时已经“没有办法”，只能创建新的线程（小于maximumPoolSize的部分）来执行。

4）当然，如果maximumPoolSize也Hold不住，只能把任务扔了。

1 楼 mengjun004 2012-01-09  

参考JDK文档，它的描述应该是这样的：
1） 如果空闲的线程数小于corePoolSize，创建新线程
2） 如果提交的线程数大于corePoolSize并且小于maximumPoolSize，只会有等于corePoolSize的线程数被创建，然后将打印任务提交到队列中，直到队列满了，才会创建小于等于maximumPoolSize的线程，然后将多余的任务处理掉。

请牛人解析下，谢谢！