阻塞队列和线程池

1.阻塞队列

1）支持阻塞的插入方法：意思是当队列满时，队列会阻塞插入元素的线程，直到队列不满。
2）支持阻塞的移除方法：意思是在队列为空时，获取元素的线程会等待队列变为非空。
在并发编程中使用生产者和消费者模式能够解决绝大多数并发问题。该模式通过平衡生产线程和消费线程的工作能力来提高程序整体处理数据的速度。

• BlockingQueue常用方法 BlockingQueue

• 常用阻塞队列
  ArrayBlockingQueue：一个由数组结构组成的有界阻塞队列。
  LinkedBlockingQueue：一个由链表结构组成的有界阻塞队列。
  PriorityBlockingQueue：一个支持优先级排序的无界阻塞队列。
  DelayQueue：一个使用优先级队列实现的无界阻塞队列。
  SynchronousQueue：一个不存储元素的阻塞队列。
  LinkedTransferQueue：一个由链表结构组成的无界阻塞队列。
  LinkedBlockingDeque：一个由链表结构组成的双向阻塞队列。

• 有界无界？
  有界队列就是长度有限，满了以后生产者会阻塞，无界队列就是里面能放无数的东西而不会因为队列长度限制被阻塞。

2.线程池

• 为什么要用线程池？
  第一：降低资源消耗。
  第二：提高响应速度。
  第三：提高线程的可管理性。

  
  线程池继承关系

• 线程池的创建各个参数含义

public ThreadPoolExecutor(int corePoolSize,int maximumPoolSize,
      long keepAliveTime,TimeUnit unit,
      BlockingQueue<Runnable> workQueue,
      ThreadFactory threadFactory,
      RejectedExecutionHandler handler)

1.corePoolSize : 线程池中的核心线程数
2.maximumPoolSize : 线程池中允许的最大线程数
3.keepAliveTime : 线程空闲时的存活时间
4.TimeUnit : keepAliveTime的时间单位
5.workQueue : workQueue必须是BlockingQueue阻塞队列。当线程池中的线程数超过它的corePoolSize的时候，线程会进入阻塞队列进行阻塞等待
6.threadFactory : 创建线程的工厂，通过自定义的线程工厂可以给每个新建的线程设置一个具有识别度的线程名，当然还可以更加自由的对线程做更多的设置
7.RejectedExecutionHandler : 线程池的饱和策略，当阻塞队列满了，且没有空闲的工作线程，如果继续提交任务，必须采取一种策略处理该任务

• 线程池的工作机制
  1）如果当前运行的线程少于corePoolSize，则创建新线程来执行任务（注意，执行这一步骤需要获取全局锁）。
  2）如果运行的线程等于或多于corePoolSize，则将任务加入BlockingQueue。
  3）如果无法将任务加入BlockingQueue（队列已满），则创建新的线程来处理任务。
  4）如果创建新线程将使当前运行的线程超出maximumPoolSize，任务将被拒绝，并调用RejectedExecutionHandler.rejectedExecution()方法。

• 合理地配置线程池
  CPU密集型任务： Runtime.getRuntime().availableProcessors()配置最大线程数
  IO密集型任务 ： 线程数 ：机器CPU核心数*2
  混合型任务 ： 线程池拆分