最近在看OkHttp的原始碼，看著看著就看到了有執行緒池的地方，以前自己對這個東西就也就感到雲裡霧裡的，所以

想把執行緒池的知識點和原始碼完整的看一篇

  1.執行緒池有什麼用?

    a.重用執行緒池中存在的執行緒，避免因為執行緒的大量建立和銷燬所帶來的效能開銷 ，完成一項任務的時間T=建立線

程的時間+線上程中執行任務的時間+執行緒銷燬的時間， 而執行緒池的出現可以大大減少建立執行緒的時間和執行緒銷燬的

時間，從而提高app的效能
    
    b.能有限的控制執行緒池的最大併發數,並且大量的執行緒互相搶佔資源而導致的阻塞現象
    c.對執行緒池中執行緒進行有效的跟進,當我們不需要處理的時候可以將它shutdow掉
   並提供定時執行以及制定間隔迴圈執行， 

    2.ThreadPoolExcutor類詳解

   threadPoolExcutor是執行緒池中最核心的類，所以要想弄懂執行緒池一定要弄懂這個類

   （1）首先來了解一下構造方法:

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

   corePoolSize：核心執行緒池大小
   maximumPoolSize：最大執行緒池大小
   keepAliveTime：當一個執行緒無事可做，超過一定的時間（keepAliveTime）時，執行緒池會判斷，
                       如果當前執行的執行緒數大於 corePoolSize，那麼這個執行緒就被停掉。
   unit：keepAliveTime時間單位
   workQueue：阻塞任務佇列
   threadFactory：新建執行緒工廠
   handler:    當提交任務數超過maxmumPoolSize+workQueue之和時，任務會交給RejectedExecutionHandler來做拒絕處理

   （2）BlockingQueue詳解:用於儲存等待執行的執行緒任務的阻塞佇列
        ArrayBlockingQueue(少):是一個基於陣列結構的有界阻塞佇列，此佇列按 FIFO（先進先出）原則對元素進行排序。      
        LinkedBlockingQueue:一個基於連結串列結構的阻塞佇列，此佇列按FIFO （先進先出） 排序元素，吞吐量通常要高於ArrayBlockingQueue  靜態工廠方法Executors.newFixedThreadPool()使用了這個佇列，如果不執行佇列的大小，那麼該

佇列就是一個無界佇列，無界佇列的特徵見PriorityBlockingQueue                       
        SynchronousQueue:一個不儲存元素的阻塞佇列。每個插入操作必須等到另一個執行緒呼叫移除操作，否則插入操作一直處於阻塞狀態，它將任務直接提交給執行緒而不保持它們。在此，如果不存在可用於立即執行任務的執行緒，則試圖把任務加入佇列將失敗，因此會構造一個新的執行緒         
       PriorityBlockingQueue(少):一個具有優先順序的無限阻塞佇列,使用無界佇列將導致將導致在所有 corePoolSize 執行緒都忙時新任務在佇列中等待。這樣，建立的執行緒就不會超過 corePoolSize。（因此，maximumPoolSize和keepAliveTime的值也就無效了）
       
           
   （3）ThreadFactory作用:
       執行緒工廠，主要用來根據提交的新任務建立執行緒物件
      

 static class PicassoThreadFactory implements ThreadFactory {
         @SuppressWarnings("NullableProblems")
         public Thread newThread(Runnable r) {
           return new Thread(r);
        }
     }     

   （4）ThreadPoolExcutor的執行步驟

      ①、當呼叫 execute() 方法新增一個任務時，執行緒池會做如下判斷：
      a. 如果正在執行的執行緒數量小於 corePoolSize，那麼馬上建立執行緒執行這個任務；
      b. 如果正在執行的執行緒數量大於或等於 corePoolSize，那麼將這個任務放入佇列。
      c. 如果這時候佇列滿了，而且正在執行的執行緒數量小於 maximumPoolSize，那麼還是要建立執行緒執行這個任務；
      d. 如果佇列滿了，而且正在執行的執行緒數量大於或等於 maximumPoolSize，那麼執行緒池會丟擲異常，告訴呼叫者

“我不能再接受任務了”。
      ②、當一個執行緒完成任務時，它會從佇列中取下一個任務來執行。

      ③、當一個執行緒無事可做，超過一定的時間（keepAliveTime）時，執行緒池會判斷，如果當前執行的執行緒數大於

corePoolSize，那麼這個執行緒就被停掉。所以執行緒池的所有任務完成後，它最終會收縮到 corePoolSize 的大小。

這個過程說明，並不是先加入任務就一定會先執行。假設佇列大小為 4，corePoolSize為2，maximumPoolSize為6，

那麼當加入15個任務時，執行的順序類似這樣：首先執行任務 1、2，然後任務3~6被放入佇列。這時候佇列滿了，

任務7、8、9、10 會被馬上執行，而任務 11~15 則會丟擲異常。最終順序是：1、2、7、8、9、10、3、4、5、6。

當然這個過程是針對指定大小的ArrayBlockingQueue<Runnable>來說，如果無界佇列,那麼3-15的任務都會加到佇列

中

  3.ThreadPoolExcutor的使用

（1）newFixedThreadPool(2)
      

     //指定了corePoolSize與maximumPoolSize為2
     ExecutorServicer pool=Executors.newFixedThreadPool(2);
     // 建立執行緒  
     Thread t1 = new MyThread();  
     Thread t2 = new MyThread();  
     Thread t3 = new MyThread();  
     // 將執行緒放入池中進行執行  
     pool.execute(t1);  
     pool.execute(t2);  
     pool.execute(t3);  
     // 關閉執行緒池  
     pool.shutdown();  
     private class MtThread extends Thread{...}  

       // 建立一個執行緒池，它可安排在給定延遲後執行命令或者定期地執行。  
        ScheduledExecutorService pool = Executors.newScheduledThreadPool(2);  
        // 建立實現了Runnable介面物件，Thread物件當然也實現了Runnable介面  
        Thread t1 = new MyThread();  
        Thread t2 = new MyThread();  
        Thread t3 = new MyThread();  
        // 將執行緒放入池中進行執行  
        pool.execute(t1);  
        // 使用延遲執行風格的方法  
        pool.schedule(t2, 1000, TimeUnit.MILLISECONDS);  
        pool.schedule(t3, 10, TimeUnit.MILLISECONDS);  
         
        // 關閉執行緒池  
        pool.shutdown(); 

來自定義執行緒池

  （5）ThreadPoolExecutor中幾個重要的方法

① execute(Runnable r):向執行緒池新增一個執行緒任務
   ② Future<?> submit(Runnable r):向執行緒池新增一個執行緒任務,可以返回任務執行結果
   ③ shutdown():關閉執行緒池,不接收新的任務,關閉後，正在等待執行的任務不受任何影響，會正常執行,無返回值!
   ④ shutdownNow():關閉執行緒池，也不接收新的Task，並停止正等待執行的Task（也就是說，
   執行到一半的任務將正常執行下去），最終還會給你返回一個正在等待執行但執行緒池關閉卻沒有被執行的Task集合

   我們執行Runnable任務，他的run（）方法是沒有返回值的，那如果我們想要執行完一個任務，並且能夠拿到一個返回值結果，那麼應該怎麼做呢？這個在我的另一篇部落格已經將的很清楚了就不重複講了Future和Callable詳解