建站
咨詢
售后
建站咨詢
新聞中心
想了解更多內(nèi)容，請(qǐng)?jiān)L問(wèn)：
創(chuàng)新互聯(lián)-專業(yè)網(wǎng)站定制、快速模板網(wǎng)站建設(shè)、高性價(jià)比牡丹江網(wǎng)站開(kāi)發(fā)、企業(yè)建站全套包干低至880元,成熟完善的模板庫(kù),直接使用。一站式牡丹江網(wǎng)站制作公司更省心,省錢,快速模板網(wǎng)站建設(shè)找我們，業(yè)務(wù)覆蓋牡丹江地區(qū)。費(fèi)用合理售后完善，10年實(shí)體公司更值得信賴。
和華為官方合作共建的鴻蒙技術(shù)社區(qū)
https://harmonyos.
概述
不同應(yīng)用在各自獨(dú)立的進(jìn)程中運(yùn)行。當(dāng)應(yīng)用以任何形式啟動(dòng)時(shí)，系統(tǒng)為其創(chuàng)建進(jìn)程，該進(jìn)程將持續(xù)運(yùn)行。當(dāng)進(jìn)程完成當(dāng)前任務(wù)處于等待狀態(tài)，且系統(tǒng)資源不足時(shí)，系統(tǒng)自動(dòng)回收。
在啟動(dòng)應(yīng)用時(shí)，系統(tǒng)會(huì)為該應(yīng)用創(chuàng)建一個(gè)稱為“主線程”的執(zhí)行線程。該線程隨著應(yīng)用創(chuàng)建或消失，是應(yīng)用的核心線程。UI界面的顯示和更新等操作，都是在主線程上進(jìn)行。主線程又稱UI線程，默認(rèn)情況下，所有的操作都是在主線程上執(zhí)行。如果需要執(zhí)行比較耗時(shí)的任務(wù)(如下載文件、查詢數(shù)據(jù)庫(kù))，可創(chuàng)建其他線程來(lái)處理。
如果應(yīng)用的業(yè)務(wù)邏輯比較復(fù)雜，可能需要?jiǎng)?chuàng)建多個(gè)線程來(lái)執(zhí)行多個(gè)任務(wù)。這種情況下，代碼復(fù)雜難以維護(hù)，任務(wù)與線程的交互也會(huì)更加繁雜。要解決此問(wèn)題，開(kāi)發(fā)者可以使用TaskDispatcher來(lái)分發(fā)不同的任務(wù)。
TaskDispatcher介紹
TaskDispatcher是一個(gè)任務(wù)分發(fā)器，它是Ability分發(fā)任務(wù)的基本接口，隱藏任務(wù)所在線程的實(shí)現(xiàn)細(xì)節(jié)。
為保證應(yīng)用有更好的響應(yīng)性，我們需要設(shè)計(jì)任務(wù)的優(yōu)先級(jí)。在UI線程上運(yùn)行的任務(wù)默認(rèn)以高優(yōu)先級(jí)運(yùn)行，如果某個(gè)任務(wù)無(wú)需等待結(jié)果，則可以用低優(yōu)先級(jí)。
線程優(yōu)先級(jí)介紹：
HIGH：最高任務(wù)優(yōu)先級(jí)，比默認(rèn)優(yōu)先級(jí)、低優(yōu)先級(jí)的任務(wù)有更高的幾率得到執(zhí)行。
DEFAULT：默認(rèn)任務(wù)優(yōu)先級(jí)， 比低優(yōu)先級(jí)的任務(wù)有更高的幾率得到執(zhí)行。
LOW：低任務(wù)優(yōu)先級(jí)，比高優(yōu)先級(jí)、默認(rèn)優(yōu)先級(jí)的任務(wù)有更低的幾率得到執(zhí)行。
TaskDispatcher具有多種實(shí)現(xiàn)，每種實(shí)現(xiàn)對(duì)應(yīng)不同的任務(wù)分發(fā)器。在分發(fā)任務(wù)時(shí)可以指定任務(wù)的優(yōu)先級(jí)，由同一個(gè)任務(wù)分發(fā)器分發(fā)出的任務(wù)具有相同的優(yōu)先級(jí)。系統(tǒng)提供的任務(wù)分發(fā)器有GlobalTaskDispatcher、ParallelTaskDispatcher、SerialTaskDispatcher 、SpecTaskDispatcher。
實(shí)踐
1.同步派發(fā)任務(wù)syncDispatch
發(fā)任務(wù)并在當(dāng)前線程等待任務(wù)執(zhí)行完成。在返回前，當(dāng)前線程會(huì)被阻塞
- /**
- * 同步派發(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");
- }
運(yùn)行之后查看日志:
從運(yùn)行結(jié)果我們可以看到，只有在當(dāng)前線程等待任務(wù)執(zhí)行完成之后才會(huì)繼續(xù)往下執(zhí)行，否則當(dāng)前線程會(huì)被阻塞，所以在使用syncDispatch的時(shí)候我們需要注意，如果對(duì)syncDispatch使用不當(dāng), 將會(huì)導(dǎo)致死鎖。如下情形可能導(dǎo)致死鎖發(fā)生：
- 在專有線程上，利用該專有任務(wù)分發(fā)器進(jìn)行syncDispatch。
- 在被某個(gè)串行任務(wù)分發(fā)器(dispatcher_a)派發(fā)的任務(wù)中，再次利用同一個(gè)串行任務(wù)分發(fā)器(dispatcher_a)對(duì)象派發(fā)任務(wù)。
- 在被某個(gè)串行任務(wù)分發(fā)器(dispatcher_a)派發(fā)的任務(wù)中，經(jīng)過(guò)數(shù)次派發(fā)任務(wù)，最終又利用該(dispatcher_a)串行任務(wù)分發(fā)器派發(fā)任務(wù)。例如：dispatcher_a派發(fā)的任務(wù)使用dispatcher_b進(jìn)行任務(wù)的派發(fā)，在dispatcher_b派發(fā)的任務(wù)中又利用dispatcher_a進(jìn)行派發(fā)任務(wù)。
- 串行任務(wù)分發(fā)器(dispatcher_a)派發(fā)的任務(wù)中利用串行任務(wù)分發(fā)器(dispatcher_b)進(jìn)行同步派發(fā)任務(wù)，同時(shí)dispatcher_b派發(fā)的任務(wù)中利用串行任務(wù)分發(fā)器(dispatcher_a)進(jìn)行同步派發(fā)任務(wù)。在特定的線程執(zhí)行順序下將導(dǎo)致死鎖。
2.異步派發(fā)任務(wù)asyncDispatch
派發(fā)任務(wù)，并立即返回，返回值是一個(gè)可用于取消任務(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");
- }
運(yùn)行之后查看日志:
從運(yùn)行結(jié)果我們可以看到，只有在當(dāng)前線程等待任務(wù)執(zhí)行完成之后才會(huì)繼續(xù)往下執(zhí)行，否則當(dāng)前線程會(huì)被阻塞，所以在使用
3. 異步延遲派發(fā)任務(wù)delayDispatch
異步執(zhí)行，函數(shù)立即返回，內(nèi)部會(huì)在延時(shí)指定時(shí)間后將任務(wù)派發(fā)到相應(yīng)隊(duì)列中。延時(shí)時(shí)間參數(shù)僅代表在這段時(shí)間以后任務(wù)分發(fā)器會(huì)將任務(wù)加入到隊(duì)列中，任務(wù)的實(shí)際執(zhí)行時(shí)間可能晚于這個(gè)時(shí)間。具體比這個(gè)數(shù)值晚多久，取決于隊(duì)列及內(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");
- }
運(yùn)行之后查看日志:
從運(yùn)行結(jié)果我們可以看出，程序首先執(zhí)行"after delayDispatch task1"，然后執(zhí)行"delayDispatch task1 run"，最后執(zhí)行"actualDelayTime >= delayTime: %{public}b", (actualDelay >= delayTime)，這里 actualDelayTime >= delayTime: true可以看出延時(shí)時(shí)間參數(shù)僅代表在這段時(shí)間以后任務(wù)分發(fā)器會(huì)將任務(wù)加入到隊(duì)列中，任務(wù)的實(shí)際執(zhí)行時(shí)間可能晚于這個(gè)時(shí)間。
4. 任務(wù)組Group
表示一組任務(wù)，且該組任務(wù)之間有一定的聯(lián)系，由TaskDispatcher執(zhí)行createDispatchGroup創(chuàng)建并返回。將任務(wù)加入任務(wù)組，返回一個(gè)用于取消任務(wù)的接口。
- /**
- * 任務(wù)組
- */
- private void dispatchGroup() {
- String dispatcherName = "parallelTaskDispatcher";
- TaskDispatcher dispatcher = createParallelTaskDispatcher(dispatcherName, TaskPriority.DEFAULT);
- // 創(chuàng)建任務(wù)組。
- Group group = dispatcher.createDispatchGroup();
- // 將任務(wù)1加入任務(wù)組，返回一個(gè)用于取消任務(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");
- }
- });
- }
運(yùn)行之后查看日志:
5. 同步設(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ù)組，返回一個(gè)用于取消任務(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
- }
運(yùn)行之后查看日志:
6. 異步設(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ù)組，返回一個(gè)用于取消任務(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
- }
運(yùn)行之后查看日志:
總結(jié)
線程它就像一面雙刃劍，用的好的時(shí)候可以給我們帶來(lái)事半功倍等效果，用的不好時(shí)就會(huì)給我們帶來(lái)困擾，并且這個(gè)困擾還不是一時(shí)半會(huì)能解決掉的(因?yàn)榘l(fā)現(xiàn)問(wèn)題的時(shí)候，往往是到了需要優(yōu)化期了，各項(xiàng)業(yè)務(wù)相互牽扯)，故在項(xiàng)目初期就需要嚴(yán)格考慮考量這些問(wèn)題了。
想了解更多內(nèi)容，請(qǐng)?jiān)L問(wèn)：
和華為官方合作共建的鴻蒙技術(shù)社區(qū)
https://harmonyos.
新聞名稱：HarmonyOS基礎(chǔ)之線程管理
轉(zhuǎn)載注明：http://www.dlmjj.cn/article/cdspcce.html
