HarmonyOS鸿蒙Next中线程间通信的场景及实现案例

HarmonyOS鸿蒙Next中线程间通信的场景及实现案例 1、通信场景

a、同语言线程间通信（ArkTS内）

场景描述：

ArkTS线程指的是包含ArkTS运行环境的线程，包括主线程、Taskpool线程、Worker线程。它们之间可以通过不同的接口进行通信。

实现方案：

b、跨语言线程间通信（C++与ArkTS）

场景描述：

ArkTS线程指的是包含ArkTS运行环境的线程，包括主线程、Taskpool线程和Worker线程。

由于HarmonyOS支持通过N-API开发C++业务，用户可以在C++层创建线程，因此C++线程存在于ArkTS线程通信的场景。

实现方案：

c、线程间模块共享

描述：

某些进程唯一的ArkTS实例初始化流程复杂，整体耗时长，放在主线程中对其进行初始化或造成应用启动耗时久和阻塞主线程的执行。将这些实例的初始化流程放在ArkTS子线程中进行初始化，初始化完成后主线程可以直接使用该实例。

实现方案：

• 步骤一：采用C++单例模式封装，上层封装JS壳，子线程进行初始化。
• 步骤二：初始化完成通知主线程，主线程导入使用该单例对象。

2、通信方案介绍

Emitter主要提供线程间发送和处理事件的能力，包括对持续订阅事件或单次订阅事件的处理、取消订阅事件、发送事件到事件队列等。

3、案例及DEMO

1、Taskpool参考：https://developer.huawei.com/consumer/cn/forum/topic/0203162147060555133?fid=0109140870620153026

2、Worker参考：https://developer.huawei.com/consumer/cn/forum/topic/0212162226831765933?fid=0109140870620153026

3、基于Emitter的实现案例

import { emitter } from '@kit.BasicServicesKit';
import { promptAction } from '@kit.ArkUI';
import { taskpool } from '@kit.ArkTS';

@Concurrent
function calcDe() {
  const event: emitter.InnerEvent = {
    eventId: 1,
    priority: emitter.EventPriority.LOW
  };
  const eventData: emitter.EventData = {
    data: {
      content: '这是taskpool线程数据',
      id: 1,
      isEmpty: false
    }
  };
  emitter.emit(event, eventData);
}

function taskpoolExecTool() {
  taskpool.execute(new taskpool.Task(calcDe))
}

@Entry
@Component
struct Index {

  registerEvent() {
    const event: emitter.InnerEvent = {
      eventId: 1,
    };
    const callback = (eventData: emitter.EventData): void => {
      promptAction.showToast({
        message: JSON.stringify(eventData)
      });
    }
    emitter.on(event, callback);
    promptAction.showToast({
      message: '主线程订阅事件成功！'
    })
  }

  aboutToAppear(): void {
    this.registerEvent();
  }

  build() {
    RelativeContainer() {
      Button('触发Taskpool线程发送消息')
        .id('HelloWorld')
        .fontSize(50)
        .fontWeight(FontWeight.Bold)
        .alignRules({
          center: { anchor: '__container__', align: VerticalAlign.Center },
          middle: { anchor: '__container__', align: HorizontalAlign.Center }
        }).onClick(() => {
          taskpoolExecTool()
      })
    }
    .height('100%')
    .width('100%')
  }
}