Okhttp的線程池和高并發(fā)

Okhttp的源碼分析

Okhttp的線程池和高并發(fā)

Okhttp鏈接池的使用

Okhttp的緩存機(jī)制

Okhttp的責(zé)任鏈模式

Okhttp的框架使用

建議安裝目錄插件食用
在實際項目中使用okhttp的時候(異步)禁荸,通常遵循以下步驟:

  1. 創(chuàng)建okhttp實例用于代理(OkhttpClient 的對象擁有自己的線程池和鏈接池右蒲,所以可以將其封裝成單例模式)

    OkhttpClient client = new OkhttpClient();
    
  2. 創(chuàng)建用于存放提交參數(shù)的RequestBody對象

    MediaType mediaType = MediaType.parse("application/json");
    RequestBody body = RequestBody.create(mediaType, RequestBodyHelper.getUserStarredRepoListInActivity(login));
    //mediaType 是傳遞的數(shù)據(jù)的MIME(媒體類型:json\xml\png\jpg\gif等)
    // 第二個參數(shù)為所需獲得的數(shù)據(jù)
    
  3. 創(chuàng)建用于發(fā)送請求的Request對象

    Request request = builder.method("POST", body).build();
    
  4. 發(fā)送請求并獲取服務(wù)器返回的數(shù)據(jù),執(zhí)行call的enqueue()(異步方式,實際使用)或者execute()(同步赶熟,第一行代碼中的例子)

    client .newCall(request).enqueue(callback)
    //okttp 的操作元是Call 對象瑰妄。
    

線程池的使用

源碼位于Dispatcher.java(依賴用的是3.8.1版本,Kotlin工作量有點大映砖。间坐。。)

/** Ready async calls in the order they'll be run. */
  private final Deque<AsyncCall> readyAsyncCalls = new ArrayDeque<>();

  /** Running asynchronous calls. Includes canceled calls that haven't finished yet. */
  private final Deque<AsyncCall> runningAsyncCalls = new ArrayDeque<>();

  /** Running synchronous calls. Includes canceled calls that haven't finished yet. */
  private final Deque<RealCall> runningSyncCalls = new ArrayDeque<>();

調(diào)度器 dispatcher 管理了三個隊列:同步運行隊列,異步運行隊列竹宋、異步等待隊列劳澄。同步暫時不做分析(加載耗時太長,用不到)異步如圖所示蜈七,注Call本質(zhì)是一個Runnable秒拔。

Runnable與Thread的區(qū)別

Thread類是在java.lang包中定義的。一個類只要繼承了Thread類同時覆寫了本類中的run()方法就可以實現(xiàn)多線程操作了宪潮,但是一個類只能繼承一個父類

在實際開發(fā)中一個多線程的操作很少使用Thread類溯警,而是通過Runnable接口完成。但是在使用Runnable定義的子類中沒有start()方法狡相,只有Thread類中才有梯轻。此時觀察Thread類,有一個構(gòu)造方法:public Thread(Runnable targer)此構(gòu)造方法接受Runnable的子類實例尽棕,也就是說可以通過Thread類來啟動Runnable實現(xiàn)的多線程喳挑。

異步請求最大同時請求數(shù)量
private int maxRequests = 64;
異步請求同一域名同時存在的最大請求數(shù)量
private int maxRequestsPerHost = 5;

Host和Call

執(zhí)行過程

  1. 用戶調(diào)用最后一步為enqueue,

    • 執(zhí)行隊列里面不足最大線程數(shù)maxRequests 并且Call 對應(yīng)的host 數(shù)目不超過maxRequestsPerHost 的時候直接把call 對象直接推入到執(zhí)行隊列
    • 否則,當(dāng)前線程數(shù)過多滔悉,就把 他推入到等待隊列中伊诵。
    synchronized void enqueue(AsyncCall call) {
        if (runningAsyncCalls.size() < maxRequests && runningCallsForHost(call) < maxRequestsPerHost) {
          runningAsyncCalls.add(call);
          executorService().execute(call);
        } else {
          readyAsyncCalls.add(call);
        }
      }
    
    
  2. 將等待隊列的線程調(diào)入到運行隊列

    可以看到在線程的執(zhí)行的時候最后都調(diào)用了, client.dispatcher().finished(this);

    @Override protected void execute() {
          boolean signalledCallback = false;
          try {
            Response response = getResponseWithInterceptorChain();
            if (retryAndFollowUpInterceptor.isCanceled()) {
              signalledCallback = true;
              responseCallback.onFailure(RealCall.this, new IOException("Canceled"));
            } else {
              signalledCallback = true;
              responseCallback.onResponse(RealCall.this, response);
            }
          } catch (IOException e) {
            if (signalledCallback) {
              // Do not signal the callback twice!
              Platform.get().log(INFO, "Callback failure for " + toLoggableString(), e);
            } else {
              responseCallback.onFailure(RealCall.this, e);
            }
          } finally {
            client.dispatcher().finished(this);
          }
        }
    
    

    進(jìn)入finish方法的底層,可以看到call 在runningAsyncCalls 隊列中被移除了(calls.remove(call)回官,并重新計算了目前正在執(zhí)行 線程數(shù)量曹宴,如果為零執(zhí)行idle。此外最重要的是通過promoteCalls進(jìn)行任務(wù)隊列的調(diào)度歉提。

    • 這里注意到remove和promotcalls的調(diào)用都加入了synchronized 同步鎖(其他試圖訪問該代碼塊的線程會被阻塞)笛坦,原因在步驟3中解釋。
    private <T> void finished(Deque<T> calls, T call, boolean promoteCalls) {
        int runningCallsCount;
        Runnable idleCallback;
        synchronized (this) {
          if (!calls.remove(call)) throw new AssertionError("Call wasn't in-flight!");
          if (promoteCalls) promoteCalls();
          runningCallsCount = runningCallsCount();
          idleCallback = this.idleCallback;
        }
    
        if (runningCallsCount == 0 && idleCallback != null) {
          idleCallback.run();
        }
      }
    
    
  3. promoteCalls任務(wù)隊列調(diào)度:

    經(jīng)過簡單的判斷后苔巨,首先remove方法版扩,將線程移出等待隊列,再通過add加入運行隊列侄泽。

    • 最開始定義過runningAsyncCalls和readyAsyncCalls為雙端隊列礁芦,其在插入和刪除的時候是非線程安全的,因此在調(diào)用他的時候(步驟2)加入了同步鎖
    • 通過循環(huán)也可以知道悼尾,每次任務(wù)調(diào)度的時候迭代器試圖要遍歷整個隊列柿扣,直到運行隊列滿時才return。這樣做要比來回傳遞計數(shù)變量(運行隊列還能添加幾個進(jìn)程)來的簡單安全诀豁。
    private void promoteCalls() {
        if (runningAsyncCalls.size() >= maxRequests) return; // Already running max capacity.
        if (readyAsyncCalls.isEmpty()) return; // No ready calls to promote.
    
        for (Iterator<AsyncCall> i = readyAsyncCalls.iterator(); i.hasNext(); ) {
          AsyncCall call = i.next();
    
          if (runningCallsForHost(call) < maxRequestsPerHost) {
            i.remove();
            runningAsyncCalls.add(call);
            executorService().execute(call);
          }
    
          if (runningAsyncCalls.size() >= maxRequests) return; // Reached max capacity.
        }
      }
    
    

執(zhí)行過程的總結(jié)

  • 用戶在調(diào)用client .newCall(request).enqueue(callback)的時候窄刘,調(diào)度器dispatcher首先檢查運行隊列是否滿,若滿則將其調(diào)度到等待隊列舷胜,每一個執(zhí)行的線程(call)在execute的結(jié)束時都會調(diào)用promotcalls,從而使得等待進(jìn)程進(jìn)入運行隊列。

  • 整體流程如下圖所示

最后編輯于
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請聯(lián)系作者
  • 序言:七十年代末烹骨,一起剝皮案震驚了整個濱河市翻伺,隨后出現(xiàn)的幾起案子,更是在濱河造成了極大的恐慌沮焕,老刑警劉巖吨岭,帶你破解...
    沈念sama閱讀 222,729評論 6 517
  • 序言:濱河連續(xù)發(fā)生了三起死亡事件,死亡現(xiàn)場離奇詭異峦树,居然都是意外死亡辣辫,警方通過查閱死者的電腦和手機(jī),發(fā)現(xiàn)死者居然都...
    沈念sama閱讀 95,226評論 3 399
  • 文/潘曉璐 我一進(jìn)店門魁巩,熙熙樓的掌柜王于貴愁眉苦臉地迎上來急灭,“玉大人,你說我怎么就攤上這事谷遂≡岵觯” “怎么了?”我有些...
    開封第一講書人閱讀 169,461評論 0 362
  • 文/不壞的土叔 我叫張陵肾扰,是天一觀的道長畴嘶。 經(jīng)常有香客問我,道長集晚,這世上最難降的妖魔是什么窗悯? 我笑而不...
    開封第一講書人閱讀 60,135評論 1 300
  • 正文 為了忘掉前任,我火速辦了婚禮偷拔,結(jié)果婚禮上蒋院,老公的妹妹穿的比我還像新娘。我一直安慰自己条摸,他們只是感情好悦污,可當(dāng)我...
    茶點故事閱讀 69,130評論 6 398
  • 文/花漫 我一把揭開白布。 她就那樣靜靜地躺著钉蒲,像睡著了一般切端。 火紅的嫁衣襯著肌膚如雪。 梳的紋絲不亂的頭發(fā)上顷啼,一...
    開封第一講書人閱讀 52,736評論 1 312
  • 那天踏枣,我揣著相機(jī)與錄音,去河邊找鬼钙蒙。 笑死茵瀑,一個胖子當(dāng)著我的面吹牛,可吹牛的內(nèi)容都是我干的躬厌。 我是一名探鬼主播马昨,決...
    沈念sama閱讀 41,179評論 3 422
  • 文/蒼蘭香墨 我猛地睜開眼,長吁一口氣:“原來是場噩夢啊……” “哼!你這毒婦竟也來了鸿捧?” 一聲冷哼從身側(cè)響起屹篓,我...
    開封第一講書人閱讀 40,124評論 0 277
  • 序言:老撾萬榮一對情侶失蹤,失蹤者是張志新(化名)和其女友劉穎匙奴,沒想到半個月后堆巧,有當(dāng)?shù)厝嗽跇淞掷锇l(fā)現(xiàn)了一具尸體泼菌,經(jīng)...
    沈念sama閱讀 46,657評論 1 320
  • 正文 獨居荒郊野嶺守林人離奇死亡,尸身上長有42處帶血的膿包…… 初始之章·張勛 以下內(nèi)容為張勛視角 年9月15日...
    茶點故事閱讀 38,723評論 3 342
  • 正文 我和宋清朗相戀三年荒揣,在試婚紗的時候發(fā)現(xiàn)自己被綠了。 大學(xué)時的朋友給我發(fā)了我未婚夫和他白月光在一起吃飯的照片笋颤。...
    茶點故事閱讀 40,872評論 1 353
  • 序言:一個原本活蹦亂跳的男人離奇死亡乳附,死狀恐怖伴澄,靈堂內(nèi)的尸體忽然破棺而出赋除,到底是詐尸還是另有隱情非凌,我是刑警寧澤举农,帶...
    沈念sama閱讀 36,533評論 5 351
  • 正文 年R本政府宣布,位于F島的核電站敞嗡,受9級特大地震影響颁糟,放射性物質(zhì)發(fā)生泄漏。R本人自食惡果不足惜棱貌,卻給世界環(huán)境...
    茶點故事閱讀 42,213評論 3 336
  • 文/蒙蒙 一箕肃、第九天 我趴在偏房一處隱蔽的房頂上張望。 院中可真熱鬧勺像,春花似錦、人聲如沸吟宦。這莊子的主人今日做“春日...
    開封第一講書人閱讀 32,700評論 0 25
  • 文/蒼蘭香墨 我抬頭看了看天上的太陽瓦阐。三九已至锋叨,卻和暖如春宛篇,著一層夾襖步出監(jiān)牢的瞬間,已是汗流浹背叫倍。 一陣腳步聲響...
    開封第一講書人閱讀 33,819評論 1 274
  • 我被黑心中介騙來泰國打工, 沒想到剛下飛機(jī)就差點兒被人妖公主榨干…… 1. 我叫王不留听诸,地道東北人蚕泽。 一個月前我還...
    沈念sama閱讀 49,304評論 3 379
  • 正文 我出身青樓,卻偏偏與公主長得像须妻,于是被迫代替她去往敵國和親。 傳聞我的和親對象是個殘疾皇子敛惊,可洞房花燭夜當(dāng)晚...
    茶點故事閱讀 45,876評論 2 361

推薦閱讀更多精彩內(nèi)容