【线程池】java线程池执行流程理解-蒲公英云

【线程池】java线程池执行流程理解

有时候项目中要使用到队列和多线程，写个例子留着随笔，方便后续使用

大家都知道，多线程是为了能更高效的运行程序，而线程池是为了控制一个进程中线程过多而导致内存溢出的问题，队列主要是为了解决了某一时刻请求过多而出现的宕机情况，同时能接收处理更多的请求，可以将多个请求放置到队列中，等待线程依次执行，而客户端则可以继续处理其它事情。

watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3JvZnRo_size_16_color_FFFFFF_t_70

线程池和队列执行顺序：
[1]线程池刚创建时，里面没有一个线程。任务队列是作为参数传进来的，不过就算队列里面有任务，线程池也不会马上执行它们。
[2]当调用execute() 方法添加一个任务时，线程池会做如下判断：
    a:如果正在运行的线程数量小于corePoolSize，那么马上创建线程运行这个任务
    b:如果正在运行的线程数量大于或等于corePoolSize，那么将这个任务放入队列
    c:如果这时候队列满了，而且正在运行的线程数量小于maximumPoolSize，那么还是要创建新的线程运行这个任务
    d:如果队列满了，而且正在运行的线程数量大于或等于maximumPoolSize，那么线程池会抛出异常，告诉调用者“我不能再接收任务”了
[3]当一个线程完成时，它会从队列中取下一个任务来执行。
[4]当一个线程无事可做，超过一定的时间时，线程池会判断，如果当前运行的线程数大于corePoolSize，那么这个线程被停掉，所以线程池的所有任务完成后，它会收缩到corePoolSzie 的大小。
这个过程说明，并不是先加入任务就一定会执行。
假设队列大小为4，corePoolSize为2，maximumPoolSize为 5那么当加入15个任务时，执行的顺序类似这样：
首先执行任务1、2，然后任务3~6被放入队列，这个时候队列满了，任务7、8、9、10会被马上执行，
而任务11~15则会抛出异常。最终的顺序是：1、2、7、8、9、10、3、4、5、6。
当然这个过程是针对指定大小的ArrayBlockingQueue<Runnable> 来说，如果是LinkedBlockingQueue<Runnable>，因为该队列无带下限制，所以不存在上述问题。

1、线程池和队列的应用小例子

(1) 线程实现类

public class ThreadTest implements Runnable {
              @Override
              public void run() {
                 /** 设置获取当前线程的名称 **/
                 System.out.println(Thread.currentThread().getName()); 
                  try{
                         /** 设置当前线程休眠3秒钟 **/
                         Thread.sleep(3000);
                     } catch(InterruptedException e) {
                        e.printStackTrace(); 
                    }
              }
       }
   (2) 主线程类
public static void main(String[] args ) throws InterruptedException {
    /** 创建一个线程队列，不指定队列大小，则无大小限制，队列存放线程超类 **/
    BlockinQueue<Runnable> queue = new LinkedBlockingQueue<Runnable>();
    /** 创建线程池对象，线程池根据参数创建指定个数的线程, 这里2指：空闲线程个数，6是指：最大线程个数，1是指：一个线程不工作时，超过该时间就**/             /** 就停止该线程，TimeUnit.DAYS是指：时间的单位,queue是指：存放需要被线程池执行的线程队列 **/
    ThreadPoolExecuter executor = new ThreadPoolExecutor(2,6,1,TimeUnit.DAYS,queue); 
          for(int i=0;i<10;i++) { 
             /** 设定每一个线程的名称 **/ 
             executor.execute(new Thread(new ThreadTest(),"ThreadName-"+i)); 
             System.out.println("线程队列大小为---->"+queue.size()); 
          }
    executor.shutdown(); 
}
 (3) 输出结果