Java线程池ThreadPoolExecutor的构造器:

public ThreadPoolExecutor(int corePoolSize,                              int maximumPoolSize,                              long keepAliveTime,                              TimeUnit unit,                              BlockingQueue<Runnable> workQueue) {        this(corePoolSize, maximumPoolSize, keepAliveTime, unit, workQueue,             Executors.defaultThreadFactory(), defaultHandler);    }


可以看出线程池使用的队列是阻塞队列BlockingQueue。

具体使用哪种队列与要使用的排队策略有关。一般来说线程池有三种排队策略:直接提交、***队列、有界队列。

直接提交策略

工作队列的默认选项是 SynchronousQueue,它将任务直接提交给线程而不保持它们。在此,如果不存在可用于立即运行任务的线程,则试图把任务加入队列将失败,因此会构造一个新的线程。此策略可以避免在处理可能具有内部依赖性的请求集时出现锁。直接提交通常要求*** maximumPoolSizes 以避免拒绝新提交的任务。当命令以超过队列所能处理的平均数连续到达时,此策略允许***线程具有增长的可能性。

SynchronousQueue是***的,也就是说他存数任务的能力是没有限制的,但是由于该Queue本身的特性,在某次添加元素后必须等待其他线程取走后才能继续添加。

***队列

使用***队列(例如,不具有预定义容量的 LinkedBlockingQueue)将导致在所有 corePoolSize 线程都忙时新任务在队列中等待。这样,创建的线程就不会超过 corePoolSize。(因此,maximumPoolSize的值也就无效了。)当每个任务完全独立于其他任务,即任务执行互不影响时,适合于使用***队列;例如,在 Web页服务器中。这种排队可用于处理瞬态突发请求,当命令以超过队列所能处理的平均数连续到达时,此策略允许***线程具有增长的可能性。

LinkedBlockingQueue是大小不固定的BlockingQueue,若其构造时指定大小,生成的BlockingQueue有大小限制,不指定大小,其大小有Integer.MAX_VALUE来决定。其所含的对象是FIFO顺序排序的。

PriorityBlockingQueue类似于LinkedBlockingQueue,但是其所含对象的排序不是FIFO,而是依据对象的自然顺序或者构造函数的Comparator决定。

有界队列

当使用有限的 maximumPoolSizes时,有界队列(如 ArrayBlockingQueue)有助于防止资源耗尽,但是可能较难调整和控制。队列大小和最大池大小可能需要相互折衷:使用大型队列和小型池可以最大限度地降低 CPU使用率、操作系统资源和上下文切换开销,但是可能导致人工降低吞吐量。如果任务频繁阻塞(例如,如果它们是 I/O边界),则系统可能为超过您许可的更多线程安排时间。使用小型队列通常要求较大的池大小,CPU使用率较高,但是可能遇到不可接受的调度开销,这样也会降低吞吐量。 


更多相关文章

  1. 多线程学习(三)多线程开发带来的问题与解决方法
  2. 多线程学习(二) 多线程创建4种方式
  3. Java线程池-当任务渐增时的处理-各个参数的含义
  4. 多线程学习(一) 线程与进程的理解
  5. Redis系列5-实现简单消息队列
  6. 多线程基础必要知识点!看了学习多线程事半功倍
  7. 多线程三分钟就可以入个门了!
  8. 记一次应用线程被阻塞的问题排查
  9. 异步获取线程计算的结果-Future

随机推荐

  1. Android绘图之2D绘图基础
  2. android面试题总结
  3. Mac上如何使用adb命令进行操作?(Android st
  4. selector 及 Shape 小结
  5. Android App开发总结
  6. 前言
  7. android如何获取手机联系人的数据库
  8. Android权限管理之Permission权限机制及
  9. Android:Android2D绘图
  10. Android使用Application总结