不同應用在各自獨立的進程中運行。當應用以任何形式啟動時，系統(tǒng)為其創(chuàng)建進程，該進程將持續(xù)運行。當進程完成當前任務處于等待狀態(tài)，且系統(tǒng)資源不足時，系統(tǒng)自動回收。

在啟動應用時，系統(tǒng)會為該應用創(chuàng)建一個稱為“主線程”的執(zhí)行線程。該線程隨著應用創(chuàng)建或消失，是應用的核心線程。UI 界面的顯示和更新等操作，都是在主線程上進行。

主線程又稱 UI 線程，默認情況下，所有的操作都是在主線程上執(zhí)行。如果需要執(zhí)行比較耗時的任務（如下載文件、查詢數(shù)據(jù)庫），可創(chuàng)建其他線程來處理。

如果應用的業(yè)務邏輯比較復雜，可能需要創(chuàng)建多個線程來執(zhí)行多個任務。這種情況下，代碼復雜難以維護，任務與線程的交互也會更加繁雜。

要解決此問題，開發(fā)者可以使用 TaskDispatcher 來分發(fā)不同的任務。

TaskDispatcher 介紹

TaskDispatcher 是一個任務分發(fā)器，它是 Ability 分發(fā)任務的基本接口，隱藏任務所在線程的實現(xiàn)細節(jié)。

為保證應用有更好的響應性，我們需要設計任務的優(yōu)先級。在 UI 線程上運行的任務默認以高優(yōu)先級運行，如果某個任務無需等待結果，則可以用低優(yōu)先級。

線程優(yōu)先級介紹：

HIGH：最高任務優(yōu)先級，比默認優(yōu)先級、低優(yōu)先級的任務有更高的幾率得到執(zhí)行。

DEFAULT：默認任務優(yōu)先級， 比低優(yōu)先級的任務有更高的幾率得到執(zhí)行。

LOW：低任務優(yōu)先級，比高優(yōu)先級、默認優(yōu)先級的任務有更低的幾率得到執(zhí)行。

TaskDispatcher 具有多種實現(xiàn)，每種實現(xiàn)對應不同的任務分發(fā)器。在分發(fā)任務時可以指定任務的優(yōu)先級，由同一個任務分發(fā)器分發(fā)出的任務具有相同的優(yōu)先級。

系統(tǒng)提供的任務分發(fā)器有：

GlobalTaskDispatcher

ParallelTaskDispatcher

SerialTaskDispatcher

SpecTaskDispatcher

實踐

①同步派發(fā)任務 syncDispatch

發(fā)任務并在當前線程等待任務執(zhí)行完成。在返回前，當前線程會被阻塞：

/**

* 同步派發(fā)任務

*/

private void syncDispatch（） {

TaskDispatcher globalTaskDispatcher = getGlobalTaskDispatcher（TaskPriority.DEFAULT）;

globalTaskDispatcher.syncDispatch（new Runnable（） {

@Override

public void run（） {

HiLog.info（LABEL_LOG， “sync task1 run”）;

}

}）;

HiLog.info（LABEL_LOG， “after sync task1”）;

globalTaskDispatcher.syncDispatch（new Runnable（） {

@Override

public void run（） {

HiLog.info（LABEL_LOG， “sync task2 run”）;

}

}）;

HiLog.info（LABEL_LOG， “after sync task2”）;

globalTaskDispatcher.syncDispatch（new Runnable（） {

@Override

public void run（） {

HiLog.info（LABEL_LOG， “sync task3 run”）;

}

}）;

HiLog.info（LABEL_LOG， “after sync task3”）;

}

運行之后查看日志：

從運行結果我們可以看到，只有在當前線程等待任務執(zhí)行完成之后才會繼續(xù)往下執(zhí)行，否則當前線程會被阻塞。

所以在使用 syncDispatch 的時候我們需要注意，如果對 syncDispatch 使用不當， 將會導致死鎖。

如下情形可能導致死鎖發(fā)生：

在專有線程上，利用該專有任務分發(fā)器進行 syncDispatch。

在被某個串行任務分發(fā)器（dispatcher_a）派發(fā)的任務中，再次利用同一個串行任務分發(fā)器（dispatcher_a）對象派發(fā)任務。

在被某個串行任務分發(fā)器（dispatcher_a）派發(fā)的任務中，經(jīng)過數(shù)次派發(fā)任務，最終又利用該（dispatcher_a）串行任務分發(fā)器派發(fā)任務。

例如：dispatcher_a 派發(fā)的任務使用 dispatcher_b 進行任務的派發(fā)，在 dispatcher_b 派發(fā)的任務中又利用 dispatcher_a 進行派發(fā)任務。

串行任務分發(fā)器（dispatcher_a）派發(fā)的任務中利用串行任務分發(fā)器（dispatcher_b）進行同步派發(fā)任務，同時 dispatcher_b 派發(fā)的任務中利用串行任務分發(fā)器（dispatcher_a）進行同步派發(fā)任務。在特定的線程執(zhí)行順序下將導致死鎖。

②異步派發(fā)任務 asyncDispatch

派發(fā)任務，并立即返回，返回值是一個可用于取消任務的接口。

/**

* 異步派發(fā)任務

*/

private void asyncDispatch（） {

TaskDispatcher globalTaskDispatcher = getGlobalTaskDispatcher（TaskPriority.DEFAULT）;

Revocable revocable = globalTaskDispatcher.asyncDispatch（new Runnable（） {

@Override

public void run（） {

HiLog.info（LABEL_LOG， “async task1 run”）;

}

}）;

HiLog.info（LABEL_LOG， “after async task1”）;

}

運行之后查看日志：

從運行結果我們可以看到，只有在當前線程等待任務執(zhí)行完成之后才會繼續(xù)往下執(zhí)行，否則當前線程會被阻塞，所以在使用。

③異步延遲派發(fā)任務 delayDispatch

異步執(zhí)行，函數(shù)立即返回，內部會在延時指定時間后將任務派發(fā)到相應隊列中。

延時時間參數(shù)僅代表在這段時間以后任務分發(fā)器會將任務加入到隊列中，任務的實際執(zhí)行時間可能晚于這個時間。

具體比這個數(shù)值晚多久，取決于隊列及內部線程池的繁忙情況。

/**

* 異步延遲派發(fā)任務

*/

private void delayDispatch（） {

final long callTime = System.currentTimeMillis（）;

final long delayTime = 50L;

TaskDispatcher globalTaskDispatcher = getGlobalTaskDispatcher（TaskPriority.DEFAULT）;

Revocable revocable = globalTaskDispatcher.delayDispatch（new Runnable（） {

@Override

public void run（） {

HiLog.info（LABEL_LOG， “delayDispatch task1 run”）;

final long actualDelay = System.currentTimeMillis（） - callTime;

HiLog.info（LABEL_LOG， “actualDelayTime 》= delayTime： %{public}b”， （actualDelay 》= delayTime））;

}

}， delayTime）;

HiLog.info（LABEL_LOG， “after delayDispatch task1”）;

}

運行之后查看日志：

從運行結果我們可以看出：

程序首先執(zhí)行“after delayDispatch task1”

然后執(zhí)行“delayDispatch task1 run”

最后執(zhí)行“actualDelayTime 》= delayTime： %{public}b”， （actualDelay 》= delayTime）

這里 actualDelayTime 》= delayTime： true 可以看出延時時間參數(shù)僅代表在這段時間以后任務分發(fā)器會將任務加入到隊列中，任務的實際執(zhí)行時間可能晚于這個時間。

④任務組 Group

表示一組任務，且該組任務之間有一定的聯(lián)系，由 TaskDispatcher 執(zhí)行 createDispatchGroup 創(chuàng)建并返回。

將任務加入任務組，返回一個用于取消任務的接口。

/**

* 任務組

*/

private void dispatchGroup（） {

String dispatcherName = “parallelTaskDispatcher”;

TaskDispatcher dispatcher = createParallelTaskDispatcher（dispatcherName， TaskPriority.DEFAULT）;

// 創(chuàng)建任務組。

Group group = dispatcher.createDispatchGroup（）;

// 將任務1加入任務組，返回一個用于取消任務的接口。

dispatcher.asyncGroupDispatch（group， new Runnable（） {

@Override

public void run（） {

HiLog.info（LABEL_LOG， “download task1 is running”）;

}

}）;

// 將與任務1相關聯(lián)的任務2加入任務組。

dispatcher.asyncGroupDispatch（group， new Runnable（） {

@Override

public void run（） {

HiLog.info（LABEL_LOG， “download task2 is running”）;

}

}）;

// 在任務組中的所有任務執(zhí)行完成后執(zhí)行指定任務。

dispatcher.groupDispatchNotify（group， new Runnable（） {

@Override

public void run（） {

HiLog.info（LABEL_LOG， “the close task is running after all tasks in the group are completed”）;

}

}）;

}

運行之后查看日志：

⑤同步設置屏障任務 syncDispatchBarrier

在任務組上設立任務執(zhí)行屏障，同步等待任務組中的所有任務執(zhí)行完成，再執(zhí)行指定任務。

/**

* 同步設置屏障任務

*/

private void syncDispatchBarrier（） {

String dispatcherName = “parallelTaskDispatcher”;

TaskDispatcher dispatcher = createParallelTaskDispatcher（dispatcherName， TaskPriority.DEFAULT）;

// 創(chuàng)建任務組。

Group group = dispatcher.createDispatchGroup（）;

// 將任務加入任務組，返回一個用于取消任務的接口。

dispatcher.asyncGroupDispatch（group， new Runnable（） {

@Override

public void run（） {

HiLog.info（LABEL_LOG， “task1 is running”）; // 1

}

}）;

dispatcher.asyncGroupDispatch（group， new Runnable（） {

@Override

public void run（） {

HiLog.info（LABEL_LOG， “task2 is running”）; // 2

}

}）;

dispatcher.syncDispatchBarrier（new Runnable（） {

@Override

public void run（） {

HiLog.info（LABEL_LOG， “barrier”）; // 3

}

}）;

HiLog.info（LABEL_LOG， “after syncDispatchBarrier”）; // 4

}

運行之后查看日志：

⑥異步設置屏障任務 asyncDispatchBarrier

在任務組上設立任務執(zhí)行屏障后直接返回，指定任務將在任務組中的所有任務執(zhí)行完成后再執(zhí)行。

/**

* 異步設置屏障任務

*/

private void asyncDispatchBarrier（） {

TaskDispatcher dispatcher = createParallelTaskDispatcher（“dispatcherName”， TaskPriority.DEFAULT）;

// 創(chuàng)建任務組。

Group group = dispatcher.createDispatchGroup（）;

// 將任務加入任務組，返回一個用于取消任務的接口。

dispatcher.asyncGroupDispatch（group， new Runnable（） {

@Override

public void run（） {

HiLog.info（LABEL_LOG， “task1 is running”）; // 1

}

}）;

dispatcher.asyncGroupDispatch（group， new Runnable（） {

@Override

public void run（） {

HiLog.info（LABEL_LOG， “task2 is running”）; // 2

}

}）;

dispatcher.asyncDispatchBarrier（new Runnable（） {

@Override

public void run（） {

HiLog.info（LABEL_LOG， “barrier”）; // 3

}

}）;

HiLog.info（LABEL_LOG， “after asyncDispatchBarrier”）; // 4

}

運行之后查看日志：

總結

線程它就像一面雙刃劍，用的好的時候可以給我們帶來事半功倍等效果，用的不好時就會給我們帶來困擾。

并且這個困擾還不是一時半會能解決掉的（因為發(fā)現(xiàn)問題的時候，往往是到了需要優(yōu)化期了，各項業(yè)務相互牽扯），故在項目初期就需要嚴格考慮考量這些問題了。

責任編輯：haq