學習參考資料：OKHttp源碼解析OKHttp源碼分析——攔截器OKhttp完全解析-攔截器
一、概括
說到OKHttp請求的同步和異步，就要提到Dispatcher分發(fā)器了，根據前兩篇的源碼分析，可以知道在發(fā)起請求時，整個框架主要通過Call來封裝每一次的請求。同時Call持有OkHttpClient和一份HttpEngine。而每一次的同步或者異步請求都會有Dispatcher的參與，不同的是：
同步
Dispatcher會在同步執(zhí)行任務隊列中記錄當前被執(zhí)行過得任務Call，同時在當前線程中去執(zhí)行Call的getResponseWithInterceptorChain（）方法，直接獲取當前的返回數(shù)據Response；
異步
首先來說一下Dispatcher，Dispatcher內部實現(xiàn)了懶加載無邊界限制的線程池方式，同時該線程池采用了 SynchronousQueue這種阻塞隊列。SynchronousQueue每個插入操作必須等待另一個線程的移除操作，同樣任何一個移除操作都等 待另一個線程的插入操作。因此此隊列內部其 實沒有任何一個元素，或者說容量是0，嚴格說并不是一種容器。由于隊列沒有容量，因此不能調用peek操作，因為只有移除元素時才有元素。顯然這是一種快 速傳遞元素的方式，也就是說在這種情況下元素總是以最快的方式從插入者（生產者）傳遞給移除者（消費者），這在多任務隊列中是最快處理任務的方式。對于高 頻繁請求的場景，無疑是最適合的。
異步執(zhí)行是通過Call.enqueue(Callback responseCallback)來執(zhí)行，在Dispatcher中添加一個封裝了Callback的Call的匿名內部類Runnable來執(zhí)行當前 的Call。這里一定要注意的地方這個AsyncCall是Call的匿名內部類。AsyncCall的execute方法仍然會回調到Call的 getResponseWithInterceptorChain方法來完成請求，同時將返回數(shù)據或者狀態(tài)通過Callback來完成。
二、源碼分析
OkHttp的任務隊列主要由兩部分組成：
1. 任務分發(fā)器dispatcher：負責為任務找到合適的執(zhí)行線程 ?2.網絡請求任務線程池
readyCalls：待執(zhí)行異步任務隊列
runningCalls：運行中異步任務隊列
executedCalls:運行中同步任務隊列
executorService:任務隊列線程池
(PS:這里附上的代碼為OKHttp2.5.0，后面有改動的源碼，會附上3.7版本的代碼，整體并不影響學習)
int corePoolSize: 最小并發(fā)線程數(shù)，這里并發(fā)同時包括空閑與活動的線程，如果是0的話，空閑一段時間后所有線程將全部被銷毀
int maximumPoolSize: 最大線程數(shù)，當任務進來時可以擴充的線程最大值，當大于了這個值就會根據丟棄處理機制來處理
long keepAliveTime: 當線程數(shù)大于corePoolSize時，多余的空閑線程的最大存活時間，類似于HTTP中的Keep-alive
TimeUnit unit: 時間單位，一般用秒
BlockingQueue workQueue: 工作隊列，先進先出，可以看出并不像Picasso那樣設置優(yōu)先隊列
ThreadFactory threadFactory: 單個線程的工廠，可以打Log，設置Daemon(即當JVM退出時，線程自動結束)等
可以看出，在Okhttp中，構建了一個閥值為[0, Integer.MAX_VALUE]的線程池，它不保留任何最小線程數(shù)，隨時創(chuàng)建更多的線程數(shù)，當線程空閑時只能活60秒，它使用了一個不存儲元素的阻塞工作隊列，一個叫做"OkHttp Dispatcher"的線程工廠。
也就是說，在實際運行中，當收到10個并發(fā)請求時，線程池會創(chuàng)建十個線程，當工作完成后，線程池會在60s后相繼關閉所有線程。
同步：
OkHttpClient client =newOkHttpClient();Requestrequest=newRequest.Builder()
.url("http://publicobject.com/helloworld.txt")
.build();Responseresponse= client.newCall(request).execute();
其中最后的call.execute();我們來看一下同步中的execute（）方法：
(PS:代碼為3.7版本)
重點為：
client.dispatcher().executed(this);
client.dispatcher().finished(this);
同步調用的執(zhí)行邏輯是：1.將對應任務加入分發(fā)器?2.執(zhí)行任務 3.執(zhí)行完成后通知dispatcher對應任務已完成，對應任務出隊
異步：
OkHttpClient client =newOkHttpClient();Requestrequest=newRequest.Builder()
.url("http://publicobject.com/helloworld.txt")
.build();
client.newCall(request).enqueue(newCallback() {
@Overridepublicvoid onFailure(Callcall, IOException e) {Log.d("OkHttp","Call Failed:"+ e.getMessage());
}
@Overridepublicvoid onResponse(Callcall,Responseresponse) throws IOException {Log.d("OkHttp","Call succeeded:"+response.message());
}
});
異步中的call.enqueue(new Callback(){})
當HttpClient的請求入隊時，根據代碼，我們可以發(fā)現(xiàn)實際上是Dispatcher進行了入隊操作。
如果滿足條件：
當前請求數(shù)小于最大請求數(shù)（64）
對單一host的請求小于閾值（5）
將該任務插入正在執(zhí)行任務隊列，并執(zhí)行對應任務。如果不滿足則將其放入待執(zhí)行隊列。
從之前的筆記中已經看過AsyncCall的execute()方法了
當任務執(zhí)行完成后，無論成功與否都會調用dispatcher.finished方法，通知分發(fā)器相關任務已結束：
空閑出多余線程，調用promoteCalls調用待執(zhí)行的任務
如果當前整個線程池都空閑下來，執(zhí)行空閑通知回調線程(idleCallback)
接下來看看promoteCalls：
promoteCalls的邏輯也很簡單：掃描待執(zhí)行任務隊列，將任務放入正在執(zhí)行任務隊列，并執(zhí)行該任務。
三、 總結
以上就是整個任務隊列的實現(xiàn)細節(jié)，總結起來有以下幾個特點：
OkHttp采用Dispatcher技術，類似于Nginx，與線程池配合實現(xiàn)了高并發(fā)，低阻塞的運行
Okhttp采用Deque作為緩存，按照入隊的順序先進先出
OkHttp最出彩的地方就是在try/finally中調用了finished函數(shù)，可以主動控制等待隊列的移動，而不是采用鎖或者wait/notify，極大減少了編碼復雜性
講解及圖片來源OKHttp源碼分析——任務隊列
