OpenHarmony worker详解

news2024/11/25 7:40:02

一，定义

worker是与主线程并行的独立线程。创建Worker的线程被称为宿主线程，Worker工作的线程被称为Worker线程。创建Worker时传入的脚本文件在Worker线程中执行，通常在Worker线程中处理耗时的操作，需要注意的是，Worker中不能直接更新Page。

worker与java中多线程的概念相似，就是开启一个独立线程，在独立线程中处理耗时任务。

对于处理耗时操作且不阻塞主线程起到了重要的作用，并且多个线程并发可以提高CPU和内存的利用率。在实际开发项目经常遇到网络请求、文件读写、大图片加载等相对耗时的操作，如果这些耗时操作都在主线程中处理，就会导致应用UI界面被卡住，无法操作。但需要注意的是：Worker线程中不能直接操作UI，需要通过消息通知UI线程进行更新，类似于android中的Handler机制。

二，worker运行机制

创建Worker的线程称为宿主线程（不一定是主线程，工作线程也支持创建Worker子线程），worker自身的线程称为Worker子线程(或Actor线程，工作线程)。每个worker子线程与宿主线程拥有独立的实例，包含基础设施，对象，代码段等。Worker子线程和宿主线程之间的通信是基于消息传递的，Worker通过序列化机制与宿主线程之间相互通信，完成命令及数据交互。

三，worker注意事项

1，不可以在library里面创建worker，只能在Ability里面创建worker

2，最多开启8个Worker

3，任务时长无限制

4，woker创建后需要手动管理生命周期

5，由于不同线程中上下文对象是不同的，因此worker线程只能使用线程安全的库，例如UI相关的非线程安全库不能使用

6，序列化传输的数据量大小限制为16MB

四，worker使用

1，新建一个worker

2，在ablity下的build-profile.json5里面添加：

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

3，在worker里面接受主线程消息，处理耗时任务，向主线程发送消息：

import worker, { ThreadWorkerGlobalScope, MessageEvents, ErrorEvent } from '@ohos.worker';


var workerPort : ThreadWorkerGlobalScope = worker.workerPort;


function count5(value) {
  return value*5;
}
function count6(value) {
  return value*6;
}


workerPort.onmessage = function(e : MessageEvents) {
  let data = e.data
  try{
    // 根据传输的数据的type选择进行操作
    switch (data.type) {
      case 0:
        setTimeout(() => {
         // 耗时结束后，向宿主线程发送消息
          workerPort.postMessage({ type: 'message', value: count5(data.value) });
        }, 3000);
        break;
      case 1:
        setTimeout(() => {
          // 耗时结束后，向宿主线程发送消息
          workerPort.postMessage({ type: 'message', value: count6(data.value) });
        }, 3000);
        break;
    }
  }
}


workerPort.onmessageerror = function(e : MessageEvents) {
  // Worker对象接收到一条无法被序列化的消息时被调用的事件处理，主线程执行
}

workerPort.onerror = function(e : ErrorEvent) {
  // 属性表示Worker在执行过程中发生异常被调用的事件处理程序，worker线程执行
}

4，主线程发送消息到worker线程，并接受worker线程的消息：


import worker from '@ohos.worker';

@Component
struct WorkerUseView {

  
  @State result:number =0 ;
  wk:worker.ThreadWorker =null

  aboutToAppear(){
    //创建worker线程
    this.wk = new worker.ThreadWorker("entry/ets/worker.ts");
    this.wk.onmessage=function(message){
      let data = message.data;
      this.result =data.value
    }.bind(this)
  }


  aboutToDisappear(){
    //销毁worker线程
    this.wk.terminate();
  }

  build() {
    Column(){
     
      Button('子线程计算90*5 模拟3s')
        .onClick(()=>{
          // 发送消息到worker线程
          this.wk.postMessage({ 'type': 0 ,'value': 90})
        })
        .margin(10)
      Button('子线程计算90*6 模拟3s')
        .onClick(()=>{
          // 发送消息到worker线程
          this.wk.postMessage({ 'type': 1 ,'value': 90})
        })
        .margin(10)
      Text("子线程计算结果："+this.result)
    }.width("100%").height("100%")
  }
}