IT评测·应用市场-qidao123.com

标题: 鸿蒙ArkTS实战开发：多线程并发-Worker [打印本页]
作者: 北冰洋以北    时间: 2024-6-9 07:44
标题: 鸿蒙ArkTS实战开发：多线程并发-Worker
1.Worker简介

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



欢迎光临 IT评测·应用市场-qidao123.com (https://dis.qidao123.com/) Powered by Discuz! X3.4