HarmonyOS开发实战( Beta5版)线程间通信场景最佳实践

2024-09-03 08:20

本文主要是介绍HarmonyOS开发实战( Beta5版)线程间通信场景最佳实践,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

简介

在应用开发中,经常会需要处理一些耗时的任务,如果全部放在主线程中执行就会导致阻塞,从而引起卡顿或者掉帧现象,降低用户体验,此时就可以将这些耗时操作放到子线程中处理。通常情况下,子线程可以独立完成自己的任务,但是很多时候需要将数据从主线程传递到子线程,或者将子线程的执行结果返回给主线程。本篇文章将通过以下几种场景和示例,呈现如何在OpenHarmony应用开发中实现主线程和子线程的数据通信。

独立的耗时任务

如果耗时任务是可以独立执行的,只需要在任务执行完毕后将结果返回给主线程,可以通过以下方式实现。

首先,引入TaskPool模块。

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

然后,实现子线程需要执行的任务。

@Concurrent // 在Task中执行的方法,需要添加@Concurrent注解,否则无法正常调用。
export function loadPicture(count: number): IconItemSource[] {let iconItemSourceList: IconItemSource[] = [];// 遍历添加6*count个IconItem的数据for (let index = 0; index < count; index++) {const numStart: number = index * 6;// 此处循环使用6张图片资源iconItemSourceList.push(new IconItemSource($r('app.media.nearby'), `item${numStart + 1}`));iconItemSourceList.push(new IconItemSource($r('app.media.scan'), `item${numStart + 2}`));iconItemSourceList.push(new IconItemSource($r('app.media.shop'), `item${numStart + 3}`));iconItemSourceList.push(new IconItemSource($r('app.media.cards'), `item${numStart + 4}`));iconItemSourceList.push(new IconItemSource($r('app.media.album'), `item${numStart + 5}`));iconItemSourceList.push(new IconItemSource($r('app.media.applet'), `item${numStart + 6}`));}return iconItemSourceList;
}

最后,通过TaskPool中的execute方法执行Task。

// ...
// 创建Task
let lodePictureTask: taskpool.Task = new taskpool.Task(loadPicture, 30);
// 执行Task,并返回结果
taskpool.execute(lodePictureTask).then((res: IconItemSource[]) => {// loadPicture方法的执行结果this.iconItemSourceList = res; 
})
// ...

多个任务同时执行

如果有多个任务同时执行,由于任务的复杂度不同,执行时间会不一样,返回数据的时间也是不可控的。如果主线程需要所有任务执行完毕的数据,可以通过下面这种方式实现。

// ...
let taskGroup: taskpool.TaskGroup = new taskpool.TaskGroup();
taskGroup.addTask(new taskpool.Task(loadPicture, 30));
taskGroup.addTask(new taskpool.Task(loadPicture, 20));
taskGroup.addTask(new taskpool.Task(loadPicture, 10));
taskpool.execute(taskGroup).then((ret: IconItemSource[][]) => {for (let i = 0; i < ret.length; i++) {for (let j = 0; j < ret[i].length; j++) {this.iconItemSourceList.push(ret[i][j]);}}
})
// ...

在该场景中,将需要执行的Task放到了一个TaskGroup里面,当TaskGroup中所有的Task都执行完毕后,会把每个Task运行的结果都放在一个数组中返回到主线程,而不是每执行完一个Task就返回一次,这样就可以在返回的数据里拿到所有的Task执行结果,方便主线程使用。

除此以外,如果Task需要处理的数据量较大(比如一个列表中有10000条数据),把这些数据都放在一个Task中处理也是比较耗时的。那么就可以将原始数据拆分成多个列表,并将每个子列表分配给一个独立的Task进行执行,并且等待全部执行完毕后拼成完整的数据,这样可以节省处理时间,提升用户体验。

Task任务与主线程通信

如果一个Task,不仅需要返回最后的执行结果,而且需要定时通知主线程状态、数据的变化,或者需要分段返回数量级较大的数据(比如从数据库中读取大量数据),可以通过下面这种方式实现。

首先,实现一个方法,用来接收Task发送的消息。

function notice(data: number): void {console.info("子线程任务已执行完,共加载图片: ", data);
}

然后,在需要执行的Task任务中,添加sendData()接口将消息发送给主线程。

// 通过Task的sendData方法,即时通知主线程信息
@Concurrent
export function loadPictureSendData(count: number): IconItemSource[] {let iconItemSourceList: IconItemSource[] = [];// 遍历添加6*count个IconItem的数据for (let index = 0; index < count; index++) {const numStart: number = index * 6;// 此处循环使用6张图片资源iconItemSourceList.push(new IconItemSource($r('app.media.nearby'), `item${numStart + 1}`));iconItemSourceList.push(new IconItemSource($r('app.media.scan'), `item${numStart + 2}`));iconItemSourceList.push(new IconItemSource($r('app.media.shop'), `item${numStart + 3}`));iconItemSourceList.push(new IconItemSource($r('app.media.cards'), `item${numStart + 4}`));iconItemSourceList.push(new IconItemSource($r('app.media.album'), `item${numStart + 5}`));iconItemSourceList.push(new IconItemSource($r('app.media.applet'), `item${numStart + 6}`));taskpool.Task.sendData(iconItemSourceList.length);}return iconItemSourceList;
}

最后,在主线程通过onReceiveData()接口接收消息。

// ...
let lodePictureTask: taskpool.Task = new taskpool.Task(loadPictureSendData, 30);
// 设置notice方法接收Task发送的消息
lodePictureTask.onReceiveData(notice);
taskpool.execute(lodePictureTask).then((res: IconItemSource[]) => {this.iconItemSourceList = res;
})
// ...

这样主线程就可以通过notice()接口接收到Task发送的数据。

Worker和主线程的即时消息通信

在ArkTS中,Worker相对于TaskPool存在一定的差异性,有数量限制但是可以长时间存在。一个Worker中可能会执行多个不同的任务,每个任务执行的时长或者返回的结果可能都不相同,主线程需要根据情况调用Worker中的不同方法,Worker则需要及时地将结果返回给主线程,此时可以通过下面的方法实现。

首先,创建一个Worker,可以根据参数执行不同的任务。

import { worker, MessageEvents, ThreadWorkerGlobalScope } from '@kit.ArkTS';const workerPort: ThreadWorkerGlobalScope = worker.workerPort;
// Worker接收主线程的消息,根据数据类型调用对应的方法
workerPort.onmessage = (e: MessageEvents): void => {if (typeof e.data === "string") {try {// 调用方法无入参let res: string = workerPort.callGlobalCallObjectMethod("picData", "setUp", 0) as string;console.info("worker: ", res);} catch (error) {// 异常处理console.error("worker: error code is " + error.code + " error message is " + error.message);}} else if (e.data instanceof Array) {// 将数据的前4条返回回去workerPort.postMessage(e.data.slice(0, 4));}
}

然后在主线程中创建这个Worker的对象,在点击Button的时候调用postMessage向Worker发送消息,通过Worker的onmessage方法接收Worker返回的数据。

import { worker, MessageEvents } from '@kit.ArkTS';
// ...
@State iconItemSourceList: IconItemSource[] = [];
// 创建Worker对象
workerInstance: worker.ThreadWorker = new worker.ThreadWorker("entry/ets/pages/workers/Worker.ts");
aboutToAppear() {// 初始化Workerthis.initWorker();for (let index = 0; index < 20; index++) {const numStart: number = index * 6;// 此处循环使用6张图片资源this.iconItemSourceList.push(new IconItemSource($r('app.media.nearby'), `item${numStart + 1}`));this.iconItemSourceList.push(new IconItemSource($r('app.media.scan'), `item${numStart + 2}`));this.iconItemSourceList.push(new IconItemSource($r('app.media.shop'), `item${numStart + 3}`));this.iconItemSourceList.push(new IconItemSource($r('app.media.cards'), `item${numStart + 4}`));this.iconItemSourceList.push(new IconItemSource($r('app.media.album'), `item${numStart + 5}`));this.iconItemSourceList.push(new IconItemSource($r('app.media.applet'), `item${numStart + 6}`));}
}
initWorker(){// 通过onmessage方法接收Worker返回的数据this.workerInstance.onmessage = (e: MessageEvents): void => {if (e.data instanceof Array) {this.iconItemSourceList = e.data;}}
}
// ...
Button('将图片变成5个', { type: ButtonType.Normal, stateEffect: true }).fontSize(14).borderRadius(8).backgroundColor('# 317aff').width(250).height(60).margin({top: 30}).onClick(() => {// 将数据传到Worker中this.workerInstance.postMessage(this.iconItemSourceList);})
// ...

在这段示例代码中,Worker做了2种不同的处理:当传入的数据是个string类型时,调用callGlobalCallObjectMethod同步调用主线程中的接口;当传入Array类型的时候,将Array的前4条数据返回给主线程。这样就可以实现主线程和Worker间的即时通信,方便主线程使用Worker的运行结果。

Worker子线程同步调用主线程的接口

如果一个接口在主线程中已经实现了,Worker需要调用该接口,那么可以使用下面这种方式实现。

首先,在主线程实现需要调用的接口,并且创建Worker对象,在Worker上注册需要调用的接口。

import { worker } from '@kit.ArkTS';
// 创建Worker对象
const workerInstance: worker.ThreadWorker = new worker.ThreadWorker("entry/ets/pages/workers/Worker.ts");class PicData {public iconItemSourceList: IconItemSource[] = [];public setUp(): string {for (let index = 0; index < 20; index++) {const numStart: number = index * 6;// 此处循环使用6张图片资源this.iconItemSourceList.push(new IconItemSource($r('app.media.nearby'), `item${numStart + 1}`));this.iconItemSourceList.push(new IconItemSource($r('app.media.scan'), `item${numStart + 2}`));this.iconItemSourceList.push(new IconItemSource($r('app.media.shop'), `item${numStart + 3}`));this.iconItemSourceList.push(new IconItemSource($r('app.media.cards'), `item${numStart + 4}`));this.iconItemSourceList.push(new IconItemSource($r('app.media.album'), `item${numStart + 5}`));this.iconItemSourceList.push(new IconItemSource($r('app.media.applet'), `item${numStart + 6}`));}return "setUpIconItemSourceList success!";}
}let picData = new PicData();
// 在Worker上注册需要调用的对象
workerInstance.registerGlobalCallObject("picData", picData);
workerInstance.postMessage("run setUp in picData");

然后,在Worker中通过callGlobalCallObjectMethod接口就可以调用主线程中的setUp()方法了。

// ...
try {// 调用方法无入参let res: string = workerPort.callGlobalCallObjectMethod("picData", "setUp", 0) as string;console.info("worker: ", res);
} catch (error) {// 异常处理console.error("worker: error code is " + error.code + " error message is " + error.message);
}
// ...

最后

小编在之前的鸿蒙系统扫盲中,有很多朋友给我留言,不同的角度的问了一些问题,我明显感觉到一点,那就是许多人参与鸿蒙开发,但是又不知道从哪里下手,因为资料太多,太杂,教授的人也多,无从选择。有很多小伙伴不知道学习哪些鸿蒙开发技术?不知道需要重点掌握哪些鸿蒙应用开发知识点?而且学习时频繁踩坑,最终浪费大量时间。所以有一份实用的鸿蒙(HarmonyOS NEXT)文档用来跟着学习是非常有必要的。 

为了确保高效学习,建议规划清晰的学习路线,涵盖以下关键阶段:

希望这一份鸿蒙学习文档能够给大家带来帮助~


 鸿蒙(HarmonyOS NEXT)最新学习路线

该路线图包含基础技能、就业必备技能、多媒体技术、六大电商APP、进阶高级技能、实战就业级设备开发,不仅补充了华为官网未涉及的解决方案

路线图适合人群:

IT开发人员:想要拓展职业边界
零基础小白:鸿蒙爱好者,希望从0到1学习,增加一项技能。
技术提升/进阶跳槽:发展瓶颈期,提升职场竞争力,快速掌握鸿蒙技术

2.视频教程+学习PDF文档

(鸿蒙语法ArkTS、TypeScript、ArkUI教程……)

 纯血版鸿蒙全套学习文档(面试、文档、全套视频等)

                   

鸿蒙APP开发必备

​​

总结

参与鸿蒙开发,你要先认清适合你的方向,如果是想从事鸿蒙应用开发方向的话,可以参考本文的学习路径,简单来说就是:为了确保高效学习,建议规划清晰的学习路线

这篇关于HarmonyOS开发实战( Beta5版)线程间通信场景最佳实践的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/1132505

相关文章

网页解析 lxml 库--实战

lxml库使用流程 lxml 是 Python 的第三方解析库,完全使用 Python 语言编写,它对 XPath表达式提供了良好的支 持,因此能够了高效地解析 HTML/XML 文档。本节讲解如何通过 lxml 库解析 HTML 文档。 pip install lxml lxm| 库提供了一个 etree 模块,该模块专门用来解析 HTML/XML 文档,下面来介绍一下 lxml 库

HarmonyOS学习(七)——UI(五)常用布局总结

自适应布局 1.1、线性布局(LinearLayout) 通过线性容器Row和Column实现线性布局。Column容器内的子组件按照垂直方向排列,Row组件中的子组件按照水平方向排列。 属性说明space通过space参数设置主轴上子组件的间距,达到各子组件在排列上的等间距效果alignItems设置子组件在交叉轴上的对齐方式,且在各类尺寸屏幕上表现一致,其中交叉轴为垂直时,取值为Vert

基于MySQL Binlog的Elasticsearch数据同步实践

一、为什么要做 随着马蜂窝的逐渐发展,我们的业务数据越来越多,单纯使用 MySQL 已经不能满足我们的数据查询需求,例如对于商品、订单等数据的多维度检索。 使用 Elasticsearch 存储业务数据可以很好的解决我们业务中的搜索需求。而数据进行异构存储后,随之而来的就是数据同步的问题。 二、现有方法及问题 对于数据同步,我们目前的解决方案是建立数据中间表。把需要检索的业务数据,统一放到一张M

这15个Vue指令,让你的项目开发爽到爆

1. V-Hotkey 仓库地址: github.com/Dafrok/v-ho… Demo: 戳这里 https://dafrok.github.io/v-hotkey 安装: npm install --save v-hotkey 这个指令可以给组件绑定一个或多个快捷键。你想要通过按下 Escape 键后隐藏某个组件,按住 Control 和回车键再显示它吗?小菜一碟: <template

Hadoop企业开发案例调优场景

需求 (1)需求:从1G数据中,统计每个单词出现次数。服务器3台,每台配置4G内存,4核CPU,4线程。 (2)需求分析: 1G / 128m = 8个MapTask;1个ReduceTask;1个mrAppMaster 平均每个节点运行10个 / 3台 ≈ 3个任务(4    3    3) HDFS参数调优 (1)修改:hadoop-env.sh export HDFS_NAMENOD

性能分析之MySQL索引实战案例

文章目录 一、前言二、准备三、MySQL索引优化四、MySQL 索引知识回顾五、总结 一、前言 在上一讲性能工具之 JProfiler 简单登录案例分析实战中已经发现SQL没有建立索引问题,本文将一起从代码层去分析为什么没有建立索引? 开源ERP项目地址:https://gitee.com/jishenghua/JSH_ERP 二、准备 打开IDEA找到登录请求资源路径位置

嵌入式QT开发:构建高效智能的嵌入式系统

摘要: 本文深入探讨了嵌入式 QT 相关的各个方面。从 QT 框架的基础架构和核心概念出发,详细阐述了其在嵌入式环境中的优势与特点。文中分析了嵌入式 QT 的开发环境搭建过程,包括交叉编译工具链的配置等关键步骤。进一步探讨了嵌入式 QT 的界面设计与开发,涵盖了从基本控件的使用到复杂界面布局的构建。同时也深入研究了信号与槽机制在嵌入式系统中的应用,以及嵌入式 QT 与硬件设备的交互,包括输入输出设

OpenHarmony鸿蒙开发( Beta5.0)无感配网详解

1、简介 无感配网是指在设备联网过程中无需输入热点相关账号信息,即可快速实现设备配网,是一种兼顾高效性、可靠性和安全性的配网方式。 2、配网原理 2.1 通信原理 手机和智能设备之间的信息传递,利用特有的NAN协议实现。利用手机和智能设备之间的WiFi 感知订阅、发布能力,实现了数字管家应用和设备之间的发现。在完成设备间的认证和响应后,即可发送相关配网数据。同时还支持与常规Sof

活用c4d官方开发文档查询代码

当你问AI助手比如豆包,如何用python禁止掉xpresso标签时候,它会提示到 这时候要用到两个东西。https://developers.maxon.net/论坛搜索和开发文档 比如这里我就在官方找到正确的id描述 然后我就把参数标签换过来

C#实战|大乐透选号器[6]:实现实时显示已选择的红蓝球数量

哈喽,你好啊,我是雷工。 关于大乐透选号器在前面已经记录了5篇笔记,这是第6篇; 接下来实现实时显示当前选中红球数量,蓝球数量; 以下为练习笔记。 01 效果演示 当选择和取消选择红球或蓝球时,在对应的位置显示实时已选择的红球、蓝球的数量; 02 标签名称 分别设置Label标签名称为:lblRedCount、lblBlueCount