線(xiàn)程模型

FA模型下的線(xiàn)程主要有如下三類(lèi)：

• 主線(xiàn)程： 負(fù)責(zé)管理其他線(xiàn)程。
• Ability線(xiàn)程：
  • 每個(gè)Ability一個(gè)線(xiàn)程。
  • 輸入事件分發(fā)。
  • UI繪制。
  • 應(yīng)用代碼回調(diào)（事件處理，生命周期）。
  • 接收Worker發(fā)送的消息。
• Worker線(xiàn)程： 執(zhí)行耗時(shí)操作。

基于當(dāng)前的線(xiàn)程模型，不同的業(yè)務(wù)功能運(yùn)行在不同的線(xiàn)程上，業(yè)務(wù)功能的交互就需要線(xiàn)程間通信。線(xiàn)程間通信目前主要有[Emitter]
開(kāi)發(fā)前請(qǐng)熟悉鴻蒙開(kāi)發(fā)指導(dǎo)文檔 ：[gitee.com/li-shizhen-skin/harmony-os/blob/master/README.md]

使用Emitter進(jìn)行線(xiàn)程間通信

[Emitter]主要提供線(xiàn)程間發(fā)送和處理事件的能力，包括對(duì)持續(xù)訂閱事件或單次訂閱事件的處理、取消訂閱事件、發(fā)送事件到事件隊(duì)列等。

Emitter的開(kāi)發(fā)步驟如下：

1. 訂閱事件

   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;
   

   // 定義一個(gè)eventId為1的事件
   let event: emitter.InnerEvent = {
     eventId: 1
   };
   
   // 收到eventId為1的事件后執(zhí)行該回調(diào)
   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')
   });
   

2. 發(fā)送事件

   import emitter from '@ohos.events.emitter';
   

   // 定義一個(gè)eventId為1的事件，事件優(yōu)先級(jí)為L(zhǎng)ow
   let event: emitter.InnerEvent = {
     eventId: 1,
     priority: emitter.EventPriority.LOW
   };
   
   let eventData: emitter.EventData = {
     data: {
       content: 'c',
       id: 1,
       isEmpty: false
     }
   };
   
   // 發(fā)送eventId為1的事件，事件內(nèi)容為eventData
   emitter.emit(event, eventData);
   

[Worker]兩種方式，其中Emitter主要適用于線(xiàn)程間的事件同步， Worker主要用于新開(kāi)一個(gè)線(xiàn)程執(zhí)行耗時(shí)任務(wù)。

Worker簡(jiǎn)介

Worker主要作用是為應(yīng)用程序提供一個(gè)多線(xiàn)程的運(yùn)行環(huán)境，可滿(mǎn)足應(yīng)用程序在執(zhí)行過(guò)程中與主線(xiàn)程分離，在后臺(tái)線(xiàn)程中運(yùn)行一個(gè)腳本操作耗時(shí)操作，極大避免類(lèi)似于計(jì)算密集型或高延遲的任務(wù)阻塞主線(xiàn)程的運(yùn)行。具體接口信息及使用方法詳情請(qǐng)見(jiàn)[Worker]。

Worker運(yùn)作機(jī)制

圖1 Worker運(yùn)作機(jī)制示意圖

創(chuàng)建Worker的線(xiàn)程稱(chēng)為宿主線(xiàn)程（不一定是主線(xiàn)程，工作線(xiàn)程也支持創(chuàng)建Worker子線(xiàn)程），Worker自身的線(xiàn)程稱(chēng)為Worker子線(xiàn)程（或Actor線(xiàn)程、工作線(xiàn)程）。每個(gè)Worker子線(xiàn)程與宿主線(xiàn)程擁有獨(dú)立的實(shí)例，包含基礎(chǔ)設(shè)施、對(duì)象、代碼段等。Worker子線(xiàn)程和宿主線(xiàn)程之間的通信是基于消息傳遞的，Worker通過(guò)序列化機(jī)制與宿主線(xiàn)程之間相互通信，完成命令及數(shù)據(jù)交互。

Worker注意事項(xiàng)

• 創(chuàng)建Worker時(shí)，有手動(dòng)和自動(dòng)兩種創(chuàng)建方式，手動(dòng)創(chuàng)建Worker線(xiàn)程目錄及文件時(shí)，還需同步進(jìn)行相關(guān)配置，詳情請(qǐng)參考[創(chuàng)建Worker的注意事項(xiàng)]。
• 使用Worker能力時(shí)，構(gòu)造函數(shù)中傳入的Worker線(xiàn)程文件的路徑在不同版本有不同的規(guī)則，詳情請(qǐng)參見(jiàn)[文件路徑注意事項(xiàng)]。
• Worker創(chuàng)建后需要手動(dòng)管理生命周期，且最多同時(shí)運(yùn)行的Worker子線(xiàn)程數(shù)量為64個(gè)，詳情請(qǐng)參見(jiàn)[生命周期注意事項(xiàng)]。
• 由于不同線(xiàn)程中上下文對(duì)象是不同的，因此Worker線(xiàn)程只能使用線(xiàn)程安全的庫(kù)，例如UI相關(guān)的非線(xiàn)程安全庫(kù)不能使用，具體請(qǐng)見(jiàn)[多線(xiàn)程安全注意事項(xiàng)]。
• 序列化傳輸?shù)臄?shù)據(jù)量大小限制為16MB。
• 使用Worker模塊時(shí)，需要在主線(xiàn)程中注冊(cè)onerror接口，否則當(dāng)worker線(xiàn)程出現(xiàn)異常時(shí)會(huì)發(fā)生jscrash問(wèn)題。
• 不支持跨HAP使用Worker線(xiàn)程文件。

創(chuàng)建Worker的注意事項(xiàng)

Worker線(xiàn)程文件需要放在"{moduleName}/src/main/ets/"目錄層級(jí)之下，否則不會(huì)被打包到應(yīng)用中。有手動(dòng)和自動(dòng)兩種創(chuàng)建Worker線(xiàn)程目錄及文件的方式。

• 手動(dòng)創(chuàng)建：開(kāi)發(fā)者手動(dòng)創(chuàng)建相關(guān)目錄及文件，此時(shí)需要配置build-profile.json5的相關(guān)字段信息，Worker線(xiàn)程文件才能確保被打包到應(yīng)用中。
  Stage模型：

  "buildOption": {
    "sourceOption": {
      "workers": [
        "./src/main/ets/workers/worker.ets"
      ]
    }
  }
  

  FA模型：

  "buildOption": {
    "sourceOption": {
      "workers": [
        "./src/main/ets/MainAbility/workers/worker.ets"
      ]
    }
  }
  

• 自動(dòng)創(chuàng)建：DevEco Studio支持一鍵生成Worker，在對(duì)應(yīng)的{moduleName}目錄下任意位置， 點(diǎn)擊鼠標(biāo)右鍵 > New > Worker ，即可自動(dòng)生成Worker的模板文件及配置信息，無(wú)需再手動(dòng)在build-profile.json5中進(jìn)行相關(guān)配置。

文件路徑注意事項(xiàng)

當(dāng)使用Worker模塊具體功能時(shí)，均需先構(gòu)造Worker實(shí)例對(duì)象，其構(gòu)造函數(shù)與API版本相關(guān)，且構(gòu)造函數(shù)需要傳入Worker線(xiàn)程文件的路徑（scriptURL）。

// 導(dǎo)入模塊
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模型下的文件路徑規(guī)則

構(gòu)造函數(shù)中的scriptURL要求如下：

• scriptURL的組成包含 {moduleName}/ets 和相對(duì)路徑 relativePath。
• relativePath是Worker線(xiàn)程文件和"{moduleName}/src/main/ets/"目錄的相對(duì)路徑。

1） 加載Ability中Worker線(xiàn)程文件場(chǎng)景

加載Ability中的worker線(xiàn)程文件，加載路徑規(guī)則：{moduleName}/ets/{relativePath}。

import { worker } from '@kit.ArkTS';

// worker線(xiàn)程文件所在路徑："entry/src/main/ets/workers/worker.ets"
const workerStage1: worker.ThreadWorker = new worker.ThreadWorker('entry/ets/workers/worker.ets');

// worker線(xiàn)程文件所在路徑："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線(xiàn)程文件場(chǎng)景

加載HSP中worker線(xiàn)程文件，加載路徑規(guī)則：{moduleName}/ets/{relativePath}。

import { worker } from '@kit.ArkTS';

// worker線(xiàn)程文件所在路徑： "hsp/src/main/ets/workers/worker.ets"
const workerStage3: worker.ThreadWorker = new worker.ThreadWorker('hsp/ets/workers/worker.ets');

3） 加載Library-[HAR]中Worker線(xiàn)程文件場(chǎng)景

加載HAR中worker線(xiàn)程文件存在以下兩種情況：

• @標(biāo)識(shí)路徑加載形式：所有種類(lèi)的模塊加載本地HAR中的Worker線(xiàn)程文件，加載路徑規(guī)則：@{moduleName}/ets/{relativePath}。
• 相對(duì)路徑加載形式：本地HAR加載該包內(nèi)的Worker線(xiàn)程文件，加載路徑規(guī)則：創(chuàng)建Worker對(duì)象所在文件與Worker線(xiàn)程文件的相對(duì)路徑。

需要注意的是：如果HAR包會(huì)被打包成三方包使用，則HAR包中使用Worker僅支持通過(guò)相對(duì)路徑加載形式創(chuàng)建。

import { worker } from '@kit.ArkTS';

// @標(biāo)識(shí)路徑加載形式：
// worker線(xiàn)程文件所在路徑: "har/src/main/ets/workers/worker.ets"
const workerStage4: worker.ThreadWorker = new worker.ThreadWorker('@har/ets/workers/worker.ets');

// 相對(duì)路徑加載形式：
// worker線(xiàn)程文件所在路徑: "har/src/main/ets/workers/worker.ets"
// 創(chuàng)建Worker對(duì)象的文件所在路徑："har/src/main/ets/components/mainpage/MainPage.ets"
const workerStage5: worker.ThreadWorker = new worker.ThreadWorker('../../workers/worker.ets');

FA模型下的文件路徑規(guī)則

構(gòu)造函數(shù)中的scriptURL為：Worker線(xiàn)程文件與"{moduleName}/src/main/ets/MainAbility"的相對(duì)路徑。

import { worker } from '@kit.ArkTS';

// 主要說(shuō)明以下三種場(chǎng)景：

// 場(chǎng)景1： Worker線(xiàn)程文件所在路徑："{moduleName}/src/main/ets/MainAbility/workers/worker.ets"
const workerFA1: worker.ThreadWorker = new worker.ThreadWorker("workers/worker.ets", {name:"first worker in FA model"});

// 場(chǎng)景2： Worker線(xiàn)程文件所在路徑："{moduleName}/src/main/ets/workers/worker.ets"
const workerFA2: worker.ThreadWorker = new worker.ThreadWorker("../workers/worker.ets");

// 場(chǎng)景3： Worker線(xiàn)程文件所在路徑："{moduleName}/src/main/ets/MainAbility/ThreadFile/workers/worker.ets"
const workerFA3: worker.ThreadWorker = new worker.ThreadWorker("ThreadFile/workers/worker.ets");

HarmonyOS與OpenHarmony鴻蒙文檔籽料：mau123789是v直接拿

生命周期注意事項(xiàng)

• Worker的創(chuàng)建和銷(xiāo)毀耗費(fèi)性能，建議開(kāi)發(fā)者合理管理已創(chuàng)建的Worker并重復(fù)使用。Worker空閑時(shí)也會(huì)一直運(yùn)行，因此當(dāng)不需要Worker時(shí)，可以調(diào)用[terminate()]接口或[parentPort.close()]方法主動(dòng)銷(xiāo)毀Worker。若Worker處于已銷(xiāo)毀或正在銷(xiāo)毀等非運(yùn)行狀態(tài)時(shí)，調(diào)用其功能接口，會(huì)拋出相應(yīng)的錯(cuò)誤。
• Worker的數(shù)量由內(nèi)存管理策略決定，設(shè)定的內(nèi)存閾值為1.5GB和設(shè)備物理內(nèi)存的60%中的較小者。在內(nèi)存允許的情況下，系統(tǒng)最多可以同時(shí)運(yùn)行64個(gè)Worker。如果嘗試創(chuàng)建的Worker數(shù)量超出這一上限，系統(tǒng)將拋出錯(cuò)誤：“Worker initialization failure, the number of workers exceeds the maximum.”。實(shí)際運(yùn)行的Worker數(shù)量會(huì)根據(jù)當(dāng)前內(nèi)存使用情況動(dòng)態(tài)調(diào)整。一旦所有Worker和主線(xiàn)程的累積內(nèi)存占用超過(guò)了設(shè)定的閾值，系統(tǒng)將觸發(fā)內(nèi)存溢出（OOM）錯(cuò)誤，導(dǎo)致應(yīng)用程序崩潰。

說(shuō)明： FA模型每個(gè)Ability都有一個(gè)獨(dú)立的線(xiàn)程，Emiter可用于Ability線(xiàn)程內(nèi)、Ability線(xiàn)程間、Ability線(xiàn)程與Worker線(xiàn)程的事件同步。

審核編輯 黃宇