線程模型
FA模型下的線程主要有如下三類:
- 主線程: 負責管理其他線程。
- Ability線程:
- 每個Ability一個線程。
- 輸入事件分發。
- UI繪制。
- 應用代碼回調(事件處理,生命周期)。
- 接收Worker發送的消息。
- Worker線程: 執行耗時操作。
基于當前的線程模型,不同的業務功能運行在不同的線程上,業務功能的交互就需要線程間通信。線程間通信目前主要有[Emitter]
開發前請熟悉鴻蒙開發指導文檔 :[gitee.com/li-shizhen-skin/harmony-os/blob/master/README.md
]
使用Emitter進行線程間通信
[Emitter]主要提供線程間發送和處理事件的能力,包括對持續訂閱事件或單次訂閱事件的處理、取消訂閱事件、發送事件到事件隊列等。
Emitter的開發步驟如下:
訂閱事件
import emitter from '@ohos.events.emitter'; import promptAction from '@ohos.promptAction'; import hilog from '@ohos.hilog'; const TAG: string = 'ThreadModel'; const DOMAIN_NUMBER: number = 0xFF00;
// 定義一個eventId為1的事件 let event: emitter.InnerEvent = { eventId: 1 }; // 收到eventId為1的事件后執行該回調 let callback = (eventData: emitter.EventData): void = > { promptAction.showToast({ message: JSON.stringify(eventData) }); hilog.info(DOMAIN_NUMBER, TAG, 'event callback:' + JSON.stringify(eventData)); }; // 訂閱eventId為1的事件 emitter.on(event, callback); promptAction.showToast({ message: $r('app.string.emitter_subscribe_success_toast') });
發送事件
import emitter from '@ohos.events.emitter';
// 定義一個eventId為1的事件,事件優先級為Low let event: emitter.InnerEvent = { eventId: 1, priority: emitter.EventPriority.LOW }; let eventData: emitter.EventData = { data: { content: 'c', id: 1, isEmpty: false } }; // 發送eventId為1的事件,事件內容為eventData emitter.emit(event, eventData);
[Worker]兩種方式,其中Emitter主要適用于線程間的事件同步, Worker主要用于新開一個線程執行耗時任務。
Worker簡介
Worker主要作用是為應用程序提供一個多線程的運行環境,可滿足應用程序在執行過程中與主線程分離,在后臺線程中運行一個腳本操作耗時操作,極大避免類似于計算密集型或高延遲的任務阻塞主線程的運行。具體接口信息及使用方法詳情請見[Worker]。
Worker運作機制
圖1 Worker運作機制示意圖
創建Worker的線程稱為宿主線程(不一定是主線程,工作線程也支持創建Worker子線程),Worker自身的線程稱為Worker子線程(或Actor線程、工作線程)。每個Worker子線程與宿主線程擁有獨立的實例,包含基礎設施、對象、代碼段等。Worker子線程和宿主線程之間的通信是基于消息傳遞的,Worker通過序列化機制與宿主線程之間相互通信,完成命令及數據交互。
Worker注意事項
- 創建Worker時,有手動和自動兩種創建方式,手動創建Worker線程目錄及文件時,還需同步進行相關配置,詳情請參考[創建Worker的注意事項]。
- 使用Worker能力時,構造函數中傳入的Worker線程文件的路徑在不同版本有不同的規則,詳情請參見[文件路徑注意事項]。
- Worker創建后需要手動管理生命周期,且最多同時運行的Worker子線程數量為64個,詳情請參見[生命周期注意事項]。
- 由于不同線程中上下文對象是不同的,因此Worker線程只能使用線程安全的庫,例如UI相關的非線程安全庫不能使用,具體請見[多線程安全注意事項]。
- 序列化傳輸的數據量大小限制為16MB。
- 使用Worker模塊時,需要在主線程中注冊onerror接口,否則當worker線程出現異常時會發生jscrash問題。
- 不支持跨HAP使用Worker線程文件。
創建Worker的注意事項
Worker線程文件需要放在"{moduleName}/src/main/ets/"目錄層級之下,否則不會被打包到應用中。有手動和自動兩種創建Worker線程目錄及文件的方式。
手動創建:開發者手動創建相關目錄及文件,此時需要配置build-profile.json5的相關字段信息,Worker線程文件才能確保被打包到應用中。
Stage模型:"buildOption": { "sourceOption": { "workers": [ "./src/main/ets/workers/worker.ets" ] } }
FA模型:
"buildOption": { "sourceOption": { "workers": [ "./src/main/ets/MainAbility/workers/worker.ets" ] } }
自動創建:DevEco Studio支持一鍵生成Worker,在對應的{moduleName}目錄下任意位置, 點擊鼠標右鍵 > New > Worker ,即可自動生成Worker的模板文件及配置信息,無需再手動在build-profile.json5中進行相關配置。
文件路徑注意事項
當使用Worker模塊具體功能時,均需先構造Worker實例對象,其構造函數與API版本相關,且構造函數需要傳入Worker線程文件的路徑(scriptURL)。
// 導入模塊
import { worker } from '@kit.ArkTS';
// API 9及之后版本使用:
const worker1: worker.ThreadWorker = new worker.ThreadWorker('entry/ets/workers/MyWorker.ets');
// API 8及之前版本使用:
const worker2: worker.Worker = new worker.Worker('entry/ets/workers/MyWorker.ets');
Stage模型下的文件路徑規則
構造函數中的scriptURL要求如下:
- scriptURL的組成包含 {moduleName}/ets 和相對路徑 relativePath。
- relativePath是Worker線程文件和"{moduleName}/src/main/ets/"目錄的相對路徑。
1) 加載Ability中Worker線程文件場景
加載Ability中的worker線程文件,加載路徑規則:{moduleName}/ets/{relativePath}。
import { worker } from '@kit.ArkTS';
// worker線程文件所在路徑:"entry/src/main/ets/workers/worker.ets"
const workerStage1: worker.ThreadWorker = new worker.ThreadWorker('entry/ets/workers/worker.ets');
// worker線程文件所在路徑:"phone/src/main/ets/ThreadFile/workers/worker.ets"
const workerStage2: worker.ThreadWorker = new worker.ThreadWorker('phone/ets/ThreadFile/workers/worker.ets');
2) 加載Library-[HSP]中Worker線程文件場景
加載HSP中worker線程文件,加載路徑規則:{moduleName}/ets/{relativePath}。
import { worker } from '@kit.ArkTS';
// worker線程文件所在路徑: "hsp/src/main/ets/workers/worker.ets"
const workerStage3: worker.ThreadWorker = new worker.ThreadWorker('hsp/ets/workers/worker.ets');
3) 加載Library-[HAR]中Worker線程文件場景
加載HAR中worker線程文件存在以下兩種情況:
- @標識路徑加載形式:所有種類的模塊加載本地HAR中的Worker線程文件,加載路徑規則:@{moduleName}/ets/{relativePath}。
- 相對路徑加載形式:本地HAR加載該包內的Worker線程文件,加載路徑規則:創建Worker對象所在文件與Worker線程文件的相對路徑。
需要注意的是:如果HAR包會被打包成三方包使用,則HAR包中使用Worker僅支持通過相對路徑加載形式創建。
import { worker } from '@kit.ArkTS';
// @標識路徑加載形式:
// worker線程文件所在路徑: "har/src/main/ets/workers/worker.ets"
const workerStage4: worker.ThreadWorker = new worker.ThreadWorker('@har/ets/workers/worker.ets');
// 相對路徑加載形式:
// worker線程文件所在路徑: "har/src/main/ets/workers/worker.ets"
// 創建Worker對象的文件所在路徑:"har/src/main/ets/components/mainpage/MainPage.ets"
const workerStage5: worker.ThreadWorker = new worker.ThreadWorker('../../workers/worker.ets');
FA模型下的文件路徑規則
構造函數中的scriptURL為:Worker線程文件與"{moduleName}/src/main/ets/MainAbility"的相對路徑。
import { worker } from '@kit.ArkTS';
// 主要說明以下三種場景:
// 場景1: Worker線程文件所在路徑:"{moduleName}/src/main/ets/MainAbility/workers/worker.ets"
const workerFA1: worker.ThreadWorker = new worker.ThreadWorker("workers/worker.ets", {name:"first worker in FA model"});
// 場景2: Worker線程文件所在路徑:"{moduleName}/src/main/ets/workers/worker.ets"
const workerFA2: worker.ThreadWorker = new worker.ThreadWorker("../workers/worker.ets");
// 場景3: Worker線程文件所在路徑:"{moduleName}/src/main/ets/MainAbility/ThreadFile/workers/worker.ets"
const workerFA3: worker.ThreadWorker = new worker.ThreadWorker("ThreadFile/workers/worker.ets");
HarmonyOS與OpenHarmony鴻蒙文檔籽料:mau123789是v直接拿
生命周期注意事項
- Worker的創建和銷毀耗費性能,建議開發者合理管理已創建的Worker并重復使用。Worker空閑時也會一直運行,因此當不需要Worker時,可以調用[terminate()]接口或[parentPort.close()]方法主動銷毀Worker。若Worker處于已銷毀或正在銷毀等非運行狀態時,調用其功能接口,會拋出相應的錯誤。
- Worker的數量由內存管理策略決定,設定的內存閾值為1.5GB和設備物理內存的60%中的較小者。在內存允許的情況下,系統最多可以同時運行64個Worker。如果嘗試創建的Worker數量超出這一上限,系統將拋出錯誤:“Worker initialization failure, the number of workers exceeds the maximum.”。實際運行的Worker數量會根據當前內存使用情況動態調整。一旦所有Worker和主線程的累積內存占用超過了設定的閾值,系統將觸發內存溢出(OOM)錯誤,導致應用程序崩潰。
說明: FA模型每個Ability都有一個獨立的線程,Emiter可用于Ability線程內、Ability線程間、Ability線程與Worker線程的事件同步。
審核編輯 黃宇
-
鴻蒙
+關注
關注
59文章
2531瀏覽量
43788
發布評論請先 登錄
鴻蒙內核源碼Task/線程技術分析

鴻蒙OS 線程管理開發指導
鴻蒙原生應用開發-ArkTS語言基礎類庫多線程并發概述
鴻蒙原生應用開發-ArkTS語言基礎類庫多線程TaskPool和Worker的對比(三)
鴻蒙原生應用開發-ArkTS語言基礎類庫多線程并發概述
DevEco Studio AI輔助開發工具兩大升級功能 鴻蒙應用開發效率再提升
BearPi-HM_Nano開發板鴻蒙OS內核編程開發——Thread多線程
多線程服務器編程模型:如何正確使用mutex 和condition variable

SCP線程模型特點

使用 Taro 開發鴻蒙原生應用 —— 快速上手,鴻蒙應用開發指南

評論