鸿蒙ArkTS实战开发：同步使命 (TaskPool和Worker)

莱莱 · 2024-8-15 02:40:10

同步使命是指在多个线程之间协调实行的使命，其目的是确保多个使命按照肯定的顺序和规则实行，比方使用锁来防止数据竞争。
同步使命的实现必要思量多个线程之间的协作和同步，以确保数据的正确性和步伐的正确实行。
由于TaskPool偏向于单个独立的使命，因此当各个同步使命之间相对独立时推荐使用TaskPool，比方一系列导入的静态方法，大概单例实现的方法。如果同步使命之间有关联性，则必要使用Worker，比方无法单例创建的类对象实现的方法。
使用TaskPool处理同步使命

当调度独立的使命，大概一系列使命为静态方法实现，大概可以通过单例构造唯一的句柄或类对象，可在差异使命线程之间使用时，推荐使用TaskPool。

定义并发函数，内部调用同步方法。
创建使命Task，通过execute()接口实行该使命，并对使命返回的结果进行操纵。
实行并发操纵。

模拟一个包含同步调用的单实例类。

// Handle.ts 代码
export default class Handle {
static getInstance(): void {
// 返回单例对象
}
static syncGet(): void {
// 同步Get方法
}
static syncSet(num: number): number {
// 模拟同步步骤1
console.info("taskpool: this is 1st print!");
// 模拟同步步骤2
console.info("taskpool: this is 2nd print!");
return num++;
}
}

复制代码

业务使用TaskPool调用相干同步方法的代码。

// Index.ets代码
import taskpool from '@ohos.taskpool';
import Handle from './Handle'; // 返回静态句柄
// 步骤1: 定义并发函数，内部调用同步方法
@Concurrent
function func(num: number): boolean {
// 调用静态类对象中实现的同步等待调用
Handle.syncSet(num);
return true;
}
// 步骤2: 创建任务并执行
async function asyncGet(): Promise<void> {
// 创建task并传入函数func
let task: taskpool.Task = new taskpool.Task(func, 1);
// 执行task任务
let res: boolean = await taskpool.execute(task) as boolean;
// 打印任务结果
console.info("taskpool: task res is: " + res);
}
@Entry
@Component
struct Index {
@State message: string = 'Hello World';
build() {
Row() {
Column() {
Text(this.message)
.fontSize(50)
.fontWeight(FontWeight.Bold)
.onClick(() => {
// 步骤3: 执行并发操作
asyncGet();
})
}
.width('100%')
.height('100%')
}
}
}

复制代码

使用Worker处理关联的同步使命

当一系列同步使命必要使用同一个句柄调度，大概必要依赖某个类对象调度，无法在差异使命池之间共享时，必要使用Worker。

在主线程中创建Worker对象，同时接收Worker线程发送回来的消息。
1. import worker from '@ohos.worker';
3. @Entry
4. @Component
5. struct Index {
6. @State message: string = 'Hello World';
8. build() {
9. Row() {
10. Column() {
11. Text(this.message)
12. .fontSize(50)
13. .fontWeight(FontWeight.Bold)
14. .onClick(() => {
15. let w: worker.ThreadWorker = new worker.ThreadWorker('entry/ets/workers/MyWorker.ts');
16. w.onmessage = (): void => {
17. // 接收Worker子线程的结果
18. }
19. w.onerror = (): void => {
20. // 接收Worker子线程的错误信息
21. }
22. // 向Worker子线程发送Set消息
23. w.postMessage({'type': 0, 'data': 'data'})
24. // 向Worker子线程发送Get消息
25. w.postMessage({'type': 1})
26. // ...
27. // 根据实际业务，选择时机以销毁线程
28. w.terminate()
29. })
30. }
31. .width('100%')
32. }
33. .height('100%')
34. }
35. }
复制代码
在Worker线程中绑定Worker对象，同时处理同步使命逻辑。
1. // handle.ts代码
2. export default class Handle {
3. syncGet() {
4. return;
5. }
7. syncSet(num: number) {
8. return;
9. }
10. }
复制代码
1. // MyWorker.ts代码
2. import worker, { ThreadWorkerGlobalScope, MessageEvents } from '@ohos.worker';
3. import Handle from './handle' // 返回句柄
5. let workerPort : ThreadWorkerGlobalScope = worker.workerPort;
7. // 无法传输的句柄，所有操作依赖此句柄
8. let handler: Handle = new Handle()
10. // Worker线程的onmessage逻辑
11. workerPort.onmessage = (e : MessageEvents): void => {
12. switch (e.data.type as number) {
13. case 0:
14. handler.syncSet(e.data.data);
15. workerPort.postMessage('success set');
16. case 1:
17. handler.syncGet();
18. workerPort.postMessage('success get');
19. }
20. }
复制代码

最后

有许多小伙伴不知道学习哪些鸿蒙开发技术？不知道必要重点掌握哪些鸿蒙应用开发知识点？而且学习时频繁踩坑，最终浪费大量时间。所以有一份实用的鸿蒙（HarmonyOS NEXT）资料用来跟着学习黑白常有须要的。
这份鸿蒙（HarmonyOS NEXT）资料包含了鸿蒙开发必掌握的核心知识要点，内容包含了（ArkTS、ArkUI开发组件、Stage模子、多端摆设、分布式应用开发、音频、视频、WebGL、OpenHarmony多媒体技术、Napi组件、OpenHarmony内核、Harmony南向开发、鸿蒙项目实战等等）鸿蒙（HarmonyOS NEXT）技术知识点。
渴望这一份鸿蒙学习资料可以或许给各人带来帮助，有必要的小伙伴自行领取，限时开源，先到先得~无套路领取！！
如果你是一名有经验的资深Android移动开发、Java开发、前端开发、对鸿蒙感兴趣以及转行人员，可以直接领取这份资料
获取这份完整版高清学习路线，请点击→纯血版全套鸿蒙HarmonyOS学习资料
鸿蒙（HarmonyOS NEXT）最新学习路线

HarmonOS基础技能

HarmonOS就业必备技能
HarmonOS多媒体技术

鸿蒙NaPi组件进阶

HarmonOS高级技能

初识HarmonOS内核
实战就业级装备开发

有了路线图，怎么能没有学习资料呢，小编也准备了一份联合鸿蒙官方发布笔记整理收纳的一套系统性的鸿蒙（OpenHarmony ）学习手册（共计1236页）与鸿蒙（OpenHarmony ）开发入门讲授视频，内容包含：ArkTS、ArkUI、Web开发、应用模子、资源分类…等知识点。
获取以上完整版高清学习路线，请点击→纯血版全套鸿蒙HarmonyOS学习资料
《鸿蒙 (OpenHarmony)开发入门讲授视频》