# 【鸿蒙开发】多线程之Worker的使用

【鸿蒙开发】多线程之Worker的使用

文章目录

【鸿蒙开发】多线程之Worker的使用
前言
一、Worker的介绍
二、注意事项
三、Worker使用示例
- 1.新建一个Worker
- 2.主线程使用Worker
- 3.子线程Worker的使用
四、效果展示

前言

本文主要介绍了多线程的方法之一，使用Worker开启多线程，介绍了如何使用Worker。之前发布过TaskPool的使用，大家可以点击链接查看。
# 【鸿蒙开发】多线程之TaskPool的使用

一、Worker的介绍

Worker 是用于多线程并行任务处理的，能利用多核优势提效。在程序里，主线程管界面交互、任务调度，Worker 线程专注耗时计算或异步操作，像处理大数据、渲染复杂图形、密集网络请求时，让主线程保持灵敏，快速响应操作。Worker最多支持64个多线程，TaskPool没有这个限制。workder是通过onMessage和postMessage发消息实现主线程和子线程的通信的，TaskPool是通过参数的方式进行通信。

二、注意事项

1、及时关闭 Worker：开发者要清楚，Worker 完成任务后，得手动关闭，如果不关闭，资源会一直被占用，导致系统性能下降，甚至可能内存泄漏。
2、避免主线程卡顿：Worker 在多线程编程里很重要，主要负责处理耗时任务，像大数据处理、频繁网络请求等。它能帮主线程分担压力，让主线程专注用户交互与任务调度，快速响应操作
3、谨慎共享资源：虽然 Worker 线程和主线程能共享部分资源，但开发时不能过度依赖。多个 Worker 线程同时读写同一共享资源，容易混乱，导致数据出错、不一致，尽量给 Worker 配独立资源。

三、Worker使用示例

1.新建一个Worker

在这里插入图片描述

2.主线程使用Worker

Worker是通过onMessage和postMessage进行主线程和子线程通信的

  //worker的使用
  getWorker() {
    const work1 = new worker.ThreadWorker("entry/ets/workers/Worker.ets")
    work1.postMessage(123) //主线程给子线程发消息
    //主线程接收消息
    work1.onmessage = (event) => {
      // event.data-可以拿到子线程发送的消息
      AlertDialog.show({ message: '收到子线程发的消息' + JSON.stringify(event)})
      work1.terminate() //worker需要自毁或者再Workers那执行workerPort.close()
    }
  }

主线程完整代码：

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

@Entry
@Component
struct Index {

  aboutToAppear(): void {
    this.getWorker()
  }

  //worker的使用
  getWorker() {
    const work1 = new worker.ThreadWorker("entry/ets/workers/Worker.ets")
    work1.postMessage(123) //主线程给子线程发消息
    //主线程接收消息
    work1.onmessage = (event) => {
      // event.data-可以拿到子线程发送的消息
      AlertDialog.show({ message: '收到子线程发的消息' + JSON.stringify(event) })
      work1.terminate() //worker需要自毁或者再Workers那执行workerPort.close()
    }
  }

  build() {
    RelativeContainer() {
    }
    .height('100%')
    .width('100%')
  }
}

注意事项：本次演示代码路径
在这里插入图片描述
如果代码测试请求数据，注意在modules.json5中开启网络权限

3.子线程Worker的使用

子线程创建时会生成代码，我们在workerPort.onmessage中处理和主线程的通信即可。

workerPort.onmessage = async (e: MessageEvents) => {
  // e.data  可以拿到主线程传的消息
  console.log(' 接收到主线程发来的消息-----> ', e.data)
  const req = http.createHttp()
  const res = await req.request('https://xxx/home/banner')
  //子线程给主线程发消息--将请求结果返回
  workerPort.postMessage(JSON.stringify(res))
  // 如果主线程没有关闭worker，主线程可以让worker自焚
  // workerPort.close() //自毁
}

子线程完整代码：

import { ErrorEvent, MessageEvents, ThreadWorkerGlobalScope, worker } from '@kit.ArkTS';
import { http } from '@kit.NetworkKit';

const workerPort: ThreadWorkerGlobalScope = worker.workerPort;

/**
 * Defines the event handler to be called when the worker thread receives a message sent by the host thread.
 * The event handler is executed in the worker thread.
 *
 * @param e message data
 */
workerPort.onmessage = async (e: MessageEvents) => {
  // e.data  可以拿到主线程传的消息
  console.log(' 接收到主线程发来的消息-----> ', e.data)
  // AlertDialog.show({ message: '接收到主线程发来的消息：' + e.data, alignment: DialogAlignment.Center })
  const req = http.createHttp()
  const res = await req.request('https://xxx/home/banner')
  //子线程给主线程发消息--将请求结果返回
  workerPort.postMessage(JSON.stringify(res))
  // 如果主线程没有关闭worker，主线程可以让worker自焚
  // workerPort.close() //自毁
}

/**
 * Defines the event handler to be called when the worker receives a message that cannot be deserialized.
 * The event handler is executed in the worker thread.
 *
 * @param e message data
 */
workerPort.onmessageerror = (e: MessageEvents) => {
}

/**
 * Defines the event handler to be called when an exception occurs during worker execution.
 * The event handler is executed in the worker thread.
 *
 * @param e error message
 */
workerPort.onerror = (e: ErrorEvent) => {
}