鸿蒙ArkTS实战开发：多线程并发-Worker

1.Worker简介

Worker主要作用是为应用程序提供一个多线程的运行环境，可满足应用程序在实行过程中与主线程分离，在背景线程中运行一个脚本操纵耗时操纵，极大制止类似于计算密集型或高耽误的使命壅闭主线程的运行。
创建Worker的线程称为宿主线程（不一定是主线程，工作线程也支持创建Worker子线程），Worker自身的线程称为Worker子线程（或Actor线程、工作线程）。每个Worker子线程与宿主线程拥有独立的实例，包含底子设施、对象、代码段等。Worker子线程和宿主线程之间的通讯是基于消息传递的，Worker通过序列化机制与宿主线程之间相互通讯，完成下令及数据交互。
2.Worker注意事项

• 创建Worker时，传入的Worker.ts路径在不同版本有不同的规则，详情请参见文件路径注意事项。
  
• Worker创建后需要手动管理生命周期，且最多同时运行的Worker子线程数目为8个，详情请参见生命周期注意事项。
  
• Ability范例的Module支持使用Worker，Library范例的Module不支持使用Worker。
  
• 创建Worker不支持使用其他Module的Worker.ts文件，即不支持跨模块调用Worker。
  
• 由于不同线程中上下文对象是不同的，因此Worker线程只能使用线程安全的库，比方UI相关的非线程安全库不能使用。
  
• 序列化传输的数据量巨细限制为16MB。
  
• 使用Worker模块时，需要在主线程中注册onerror接口，否则当worker线程出现非常时会发生jscrash问题。
  
• 不支持跨HAP使用Worker线程文件。
  

3.生命周期注意事项

Worker的创建和销毁耗费性能，发起开发者合理管理已创建的Worker并重复使用。Worker空闲时也会不绝运行，因此当不需要Worker时，可以调用terminate()接口或parentPort.close()方法主动销毁Worker。若Worker处于已销毁或正在销毁等非运行状态时，调用其功能接口，会抛出相应的错误。
Worker存在数目限制，支持最多同时存在8个Worker。
在API version 8及之前的版本，当Worker数目超出限制时，会抛出“Too many workers, the number of workers exceeds the maximum.”错误。从API version 9开始，当Worker数目超出限制时，会抛出“Worker initialization failure, the number of workers exceeds the maximum.”错误。
4.示例

1. DevEco Studio 4.0 Release中，通过File->New->Worker,创建MyWorker

复制代码

完成创建后，wokers目录与pages目录同级，所以后续声明woker时注意路径。

4.1 MyWorker.ts文件

1. import worker, { ThreadWorkerGlobalScope, MessageEvents, ErrorEvent } from '@ohos.worker';
3. const workerPort: ThreadWorkerGlobalScope = worker.workerPort;
5. /**
6.  * Defines the event handler to be called when the worker thread receives a message sent by the host thread.
7.  * The event handler is executed in the worker thread.
8.  *
9.  * @param e message data
10.  */
11. workerPort.onmessage = function (e: MessageEvents) {
12.   let oldArr = e.data;
13.   let newArr = strSort(oldArr);
14.   workerPort.postMessage(newArr);
16. }
18. /**
19.  * Defines the event handler to be called when the worker receives a message that cannot be deserialized.
20.  * The event handler is executed in the worker thread.
21.  *
22.  * @param e message data
23.  */
24. workerPort.onmessageerror = function (e: MessageEvents) {
25.   console.log("onmessageerror worker::error = " + e.data);
26. }
28. /**
29.  * Defines the event handler to be called when an exception occurs during worker execution.
30.  * The event handler is executed in the worker thread.
31.  *
32.  * @param e error message
33.  */
34. workerPort.onerror = function (e: ErrorEvent) {
35.   console.log("onerror worker::error ");
36. }
38. function strSort(inPutArr): string {
39.   let newArr = inPutArr.sort();
40.   for (let index = 0; index < newArr.length; index++) {
41.     const element = newArr[index];
42.     console.info(`ConcurrencyPage newArr js ${element}`)
43.   }
44.   return newArr;
45. }

复制代码

4.2.工作线程相关变量界说

1. [/code]     //注意ThreadWorker的路径
2. [code]

复制代码

    myWorker: worker.ThreadWorker = new worker.ThreadWorker("entry/ets/workers/MyWorker.ts");
    jsWorkerInPutArr: string[] = [];
    @State jsWorkerOutPutStr: string = ''
    @State jsWorkerInPutStr: string = 'I am,go home,go,thank you,help me,wellcome,get out,I need your help,bye bye,good night'
4.3.工作线程调度

工作线程根据输入的字符串数组，发送到工作线程中处置惩罚。处置惩罚完成后，使用jsWorkerOutPutStr接收处置惩罚效果。

1.     async executeWorkerFunc(inPutArr: string[]): Promise<void> {
2.         if (!this.jsWorkerInPutStr.length) {
3.             this.jsWorkerOutPutStr = "No input for the string to be sorted.\n";
4.             return;
5.         }
7.         for (let index = 0; index < inPutArr.length; index++) {
8.             console.log(`${this.TAG}, jsWorkerInPutStr:${inPutArr[index]}`)
9.         }
11.         this.myWorker.postMessage(inPutArr);
12.         let strFlag = false;
13.         let outPutStr = '';
14.         this.myWorker.onmessage = (e) => {
15.             outPutStr = e.data.toString();
16.             console.log(`${this.TAG}, onmessage outPutStr:${outPutStr}`)
17.             strFlag = true;
18.         }
19.         while (!strFlag) {
20.             await this.promiseCase();
21.         }
22.         this.jsWorkerOutPutStr = outPutStr;
23.     }
25.     async promiseCase(): Promise<Object | void> {
26.         let p: Promise<Object | void> = new Promise<Object>((resolve: Function, reject: Function) => {
27.             setTimeout(() => {
28.                 resolve(1)
29.             }, 100)
30.         }).then(undefined, () => {
31.         })
32.         return p;
33.     }

复制代码

4.4.UI线程中的调用

1.     Text('Worker主要作用是为应用程序提供一个多线程的运行环境，可满足应用程序在执行过程中与主线程分离，在后台线程中运行一个脚本操作耗时操作，极大避免类似于计算密集型或高延迟的任务阻塞主线程的运行')
2.                 .width('80%')
3.     Text('Worker创建后需要手动管理生命周期，且最多同时运行的Worker子线程数量为8个，详情请参见生命周期注意事项。\nAbility类型的Module支持使用Worker，Library类型的Module不支持使用Worker。\n创建Worker不支持使用其他Module的Worker.ts文件，即不支持跨模块调用Worker。\n由于不同线程中上下文对象是不同的，因此Worker线程只能使用线程安全的库，例如UI相关的非线程安全库不能使用。\n序列化传输的数据量大小限制为16MB。\n使用Worker模块时，需要在主线程中注册onerror接口，否则当worker线程出现异常时会发生jscrash问题。')
4.         .width('80%')
6.     Text(this.jsWorkerInPutStr)
7.         .width('80%').fontColor(Color.Green)
9.     Text(`Worker 字符串排序后:${this.jsWorkerOutPutStr}`)
10.         .width('80%')
12.     Button('Worker分割字符串')
13.         .width('80%')
14.         .onClick(() => {
15.             this.jsWorkerInPutArr = this.jsWorkerInPutStr.trim().split(',');
16.             this.jsWorkerOutPutStr = '';
17.             this.executeWorkerFunc(this.jsWorkerInPutArr);
18.         })

复制代码

5.效果

最后

如果你想快速提升鸿蒙技能，那么可以直接领取这份包含了：【OpenHarmony多媒体技能、Stage模子、ArkUI多端部署、分布式应用开发、音频、视频、WebGL、Napi组件、OpenHarmony内核、Harmony南向开发、鸿蒙项目实战】等技能知识点。
鸿蒙Next全套VIP学习资料←点击领取！（安全链接，放心点击）
1.鸿蒙焦点技能学习门路

2.大厂口试必问口试题

3.鸿蒙南向开发技能

 4.鸿蒙APP开发必备

 5.HarmonyOS Next 最新全套视频教程

 6.鸿蒙生态应用开发白皮书V2.0PDF

这份全套完整版的学习资料已经全部打包好，朋侪们如果需要可以点击→鸿蒙Next全套VIP学习资料免费领取（安全链接，放心点击）


免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。