<rt id="bn8ez"></rt>
<label id="bn8ez"></label>

  • <span id="bn8ez"></span>

    <label id="bn8ez"><meter id="bn8ez"></meter></label>

    xylz,imxylz

    關注后端架構、中間件、分布式和并發編程

       :: 首頁 :: 新隨筆 :: 聯系 :: 聚合  :: 管理 ::
      111 隨筆 :: 10 文章 :: 2680 評論 :: 0 Trackbacks

    [本文地址:http://m.tkk7.com/Files/xylz/Inside.Java.Concurrency_34.ThreadPool.part7_ThreadPoolExecutor_execute.pdf] 

     

    線程池任務執行流程

    我們從一個API開始接觸Executor是如何處理任務隊列的。

    java.util.concurrent.Executor.execute(Runnable)

    Executes the given task sometime in the future. The task may execute in a new thread or in an existing pooled thread. If the task cannot be submitted for execution, either because this executor has been shutdown or because its capacity has been reached, the task is handled by the current RejectedExecutionHandler.

    線程池中所有任務執行都依賴于此接口。這段話有以下幾個意思:

    1. 任務可能在將來某個時刻被執行,有可能不是立即執行。為什么這里有兩個“可能”?繼續往下面看。
    2. 任務可能在一個新的線程中執行或者線程池中存在的一個線程中執行。
    3. 任務無法被提交執行有以下兩個原因:線程池已經關閉或者線程池已經達到了容量限制。
    4. 所有失敗的任務都將被“當前”的任務拒絕策略RejectedExecutionHandler 處理。

    回答上面兩個“可能“。任務可能被執行,那不可能的情況就是上面說的情況3;可能不是立即執行,是因為任務可能還在隊列中排隊,因此還在等待分配線程執行。了解完了字面上的問題,我們再來看具體的實現。

    public void execute(Runnable command) {
       
    if (command == null)
           
    throw new NullPointerException();
       
    if (poolSize >= corePoolSize || !addIfUnderCorePoolSize(command)) {
           
    if (runState == RUNNING && workQueue.offer(command)) {
               
    if (runState != RUNNING || poolSize == 0)
                    ensureQueuedTaskHandled(command);
            }
           
    else if (!addIfUnderMaximumPoolSize(command))
                reject(command);
    // is shutdown or saturated
        }
    }

    這一段代碼看起來挺簡單的,其實這就是線程池最重要的一部分,如果能夠完全理解這一塊,線程池還是挺容易的。整個執行流程是這樣的:

    1. 如果任務command為空,則拋出空指針異常,返回。否則進行2。
    2. 如果當前線程池大小 大于或等于 核心線程池大小,進行4。否則進行3。
    3. 創建一個新工作隊列(線程,參考上一節),成功直接返回,失敗進行4。
    4. 如果線程池正在運行并且任務加入線程池隊列成功,進行5,否則進行7。
    5. 如果線程池已經關閉或者線程池大小為0,進行6,否則直接返回。
    6. 如果線程池已經關閉則執行拒絕策略返回,否則啟動一個新線程來進行執行任務,返回。
    7. 如果線程池大小 不大于 最大線程池數量,則啟動新線程來進行執行,否則進行拒絕策略,結束。

    文字描述步驟不夠簡單?下面圖形詳細表述了此過程。

    Executor.execute

    老實說這個圖比上面步驟更難以理解,那么從何入手呢。

    流程的入口很簡單,我們就是要執行一個任務(Runnable command),那么它的結束點在哪或者有哪幾個?

    根據左邊這個圖我們知道可能有以下幾種出口:

    (1)圖中的P1、P7,我們根據這條路徑可以看到,僅僅是將任務加入任務隊列(offer(command))了;

    (2)圖中的P3,這條路徑不將任務加入任務隊列,但是啟動了一個新工作線程(Worker)進行掃尾操作,用戶處理為空的任務隊列;

    (3)圖中的P4,這條路徑沒有將任務加入任務隊列,但是啟動了一個新工作線程(Worker),并且工作現場的第一個任務就是當前任務;

    (4)圖中的P5、P6,這條路徑沒有將任務加入任務隊列,也沒有啟動工作線程,僅僅是拋給了任務拒絕策略。P2是任務加入了任務隊列卻因為線程池已經關閉于是又從任務隊列中刪除,并且拋給了拒絕策略。

    如果上面的解釋還不清楚,可以去研究下面兩段代碼:

    java.util.concurrent.ThreadPoolExecutor.addIfUnderCorePoolSize(Runnable)
    java.util.concurrent.ThreadPoolExecutor.addIfUnderMaximumPoolSize(Runnable)
    java.util.concurrent.ThreadPoolExecutor.ensureQueuedTaskHandled(Runnable)

    那么什么時候一個任務被立即執行呢?

    在線程池運行狀態下,如果線程池大小 小于 核心線程池大小或者線程池已滿(任務隊列已滿)并且線程池大小 小于 最大線程池大?。ù藭r線程池大小 大于 核心線程池大小的),用程序描述為:

    runState == RUNNING && ( poolSize < corePoolSize || poolSize < maxnumPoolSize && workQueue.isFull())

    上面的條件就是一個任務能夠被立即執行的條件。

    有了execute的基礎,我們看看ExecutorService中的幾個submit方法的實現。

        public Future<?> submit(Runnable task) {
           
    if (task == null) throw new NullPointerException();
            RunnableFuture
    <Object> ftask = newTaskFor(task, null);
            execute(ftask);
           
    return ftask;
        }

       
    public <T> Future<T> submit(Runnable task, T result) {
           
    if (task == null) throw new NullPointerException();
            RunnableFuture
    <T> ftask = newTaskFor(task, result);
            execute(ftask);
           
    return ftask;
        }

       
    public <T> Future<T> submit(Callable<T> task) {
           
    if (task == null) throw new NullPointerException();
            RunnableFuture
    <T> ftask = newTaskFor(task);
            execute(ftask);
           
    return ftask;
        }

    很簡單,不是么?對于一個線程池來說復雜的地方也就在execute方法的執行流程。在下一節中我們來討論下如何獲取任務的執行結果,也就是Future類的使用和原理。

     



    ©2009-2014 IMXYLZ |求賢若渴
    posted on 2011-02-11 23:48 imxylz 閱讀(11678) 評論(2)  編輯  收藏 所屬分類: J2EEJava Concurrency

    評論

    # re: 深入淺出 Java Concurrency (34): 線程池 part 7 線程池的實現及原理 (2) 2011-02-12 15:47 yeshucheng
    新年伊始,就看看到好東西,呵呵  回復  更多評論
      

    # re: 深入淺出 Java Concurrency (34): 線程池 part 7 線程池的實現及原理 (2) 2011-05-28 17:19 devoleper
    圖中的P3,這條路徑,為什么沒有將任務加入隊列呢?我看程序是加入了的呀?JDK1.5和1.6的實現好像不太一致...  回復  更多評論
      


    ©2009-2014 IMXYLZ
    主站蜘蛛池模板: 亚洲乱色熟女一区二区三区丝袜 | 国产午夜免费高清久久影院| 亚洲AV午夜福利精品一区二区 | 免费在线观看亚洲| 中文字幕在线免费观看视频| 亚洲综合激情九月婷婷| 四虎影视在线永久免费观看| 91在线手机精品免费观看| 亚洲av纯肉无码精品动漫| 亚洲国产第一页www| 大胆亚洲人体视频| h片在线免费观看| a免费毛片在线播放| 色偷偷女男人的天堂亚洲网| 亚洲色WWW成人永久网址| 免费看少妇作爱视频| 久久免费视频99| 青青草97国产精品免费观看| 亚洲人成电影院在线观看| 亚洲色婷婷一区二区三区| 国产亚洲精品免费| 中文字幕无码播放免费| 99在线视频免费观看| 在线精品自拍亚洲第一区| 亚洲国产夜色在线观看| 亚洲热妇无码AV在线播放| 国产gav成人免费播放视频| 成人黄色免费网址| 一区二区三区无码视频免费福利| 亚洲精品无码国产片| 亚洲成年人电影网站| 亚洲成A∨人片在线观看不卡| 免费久久精品国产片香蕉| 操美女视频免费网站| 18pao国产成视频永久免费| 爽爽爽爽爽爽爽成人免费观看| 疯狂做受xxxx高潮视频免费| 亚洲一区二区无码偷拍| 亚洲乱码中文论理电影| 7777久久亚洲中文字幕蜜桃 | 亚洲精品成人无码中文毛片不卡|