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

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

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

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

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

TaskDispatcher 介紹

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

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

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

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

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

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

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

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

GlobalTaskDispatcher

ParallelTaskDispatcher

SerialTaskDispatcher

SpecTaskDispatcher

實踐

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

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

/**

* 同步派發(fā)任務(wù)

*/

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”）;

}

運行之后查看日志：

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

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

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

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

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

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

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

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

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

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

/**

* 異步派發(fā)任務(wù)

*/

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”）;

}

運行之后查看日志：

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

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

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

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

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

/**

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

*/

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”）;

}

運行之后查看日志：

從運行結(jié)果我們可以看出：

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

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

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

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

④任務(wù)組 Group

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

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

/**

* 任務(wù)組

*/

private void dispatchGroup（） {

String dispatcherName = “parallelTaskDispatcher”;

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

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

Group group = dispatcher.createDispatchGroup（）;

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

dispatcher.asyncGroupDispatch（group， new Runnable（） {

@Override

public void run（） {

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

}

}）;

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

dispatcher.asyncGroupDispatch（group， new Runnable（） {

@Override

public void run（） {

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

}

}）;

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

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”）;

}

}）;

}

運行之后查看日志：

⑤同步設(shè)置屏障任務(wù) syncDispatchBarrier

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

/**

* 同步設(shè)置屏障任務(wù)

*/

private void syncDispatchBarrier（） {

String dispatcherName = “parallelTaskDispatcher”;

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

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

Group group = dispatcher.createDispatchGroup（）;

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

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

}

運行之后查看日志：

⑥異步設(shè)置屏障任務(wù) asyncDispatchBarrier

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

/**

* 異步設(shè)置屏障任務(wù)

*/

private void asyncDispatchBarrier（） {

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

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

Group group = dispatcher.createDispatchGroup（）;

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

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

}

運行之后查看日志：

總結(jié)

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

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

責(zé)任編輯：haq