鸿蒙多线程开发——Sendable对象的序列化与冻结操作

devtools/2024/11/27 11:18:56/

1、Sendable对象的序列化与反序列化

Sendable对象的简单介绍参考文章:鸿蒙多线程开发——线程间数据通信对象03(sendable)

与JSON对象的序列化和反序列化类似,Sendable对象的序列化和反序列化是通过ArkTs提供的ASON工具来完成。

与JSON类似,我们可以通过ASON.stringify方法将对象转换成字符串,也可以通过ASON.parse方法将字符串转成Sendable对象,以便此对象在并发任务间进行高性能引用传递。

需要注意的是:

ASON.parse默认生成的Sendable对象不支持增删属性。如果需要支持返回对象的布局可变,可以指定返回类型为MAP,此时会全部返回collections.Map对象,支持增删属性。

一个序列化(ASON.stringify)使用示例如下:

import { ArkTSUtils, collections } from '@kit.ArkTS';// ...let arr = new collections.Array(1, 2, 3);let str = ArkTSUtils.ASON.stringify(arr);console.info(str); // 期望输出: '[1,2,3]'

一个反序列化(ASON.parse)使用示例如下:​​​​​​​

import { lang } from '@kit.ArkTS';import { ArkTSUtils, collections } from '@kit.ArkTS';type ISendable = lang.ISendable; let jsonText = '{"name": "John", "age": 30, "city": "ChongQing"}';let obj = ArkTSUtils.ASON.parse(jsonText) as ISendable;console.info((obj as object)?.["name"]); // 输出: 'John'console.info((obj as object)?.["age"]); // 输出: 30console.info((obj as object)?.["city"]); // 输出: 'ChongQing'

反序列化时,也可以额外传入Option字段,示例如下:​​​​​​​

import { lang } from '@kit.ArkTS';import { ArkTSUtils, collections } from '@kit.ArkTS';type ISendable = lang.ISendable;let options: ArkTSUtils.ASON.ParseOptions = {  bigIntMode: ArkTSUtils.ASON.BigIntMode.PARSE_AS_BIGINT,  parseReturnType: ArkTSUtils.ASON.ParseReturnType.OBJECT,}let numberText = '{"largeNumber":112233445566778899}';let numberObj = ArkTSUtils.ASON.parse(numberText,undefined,options) as ISendable;console.info((numberObj as object)?.["largeNumber"]);// 期望输出: 112233445566778899

ASON工具提供了的两个序列化和反序列化接口,定义如下:​​​​​​​

// 序列化ISendable对象stringify(value: ISendable | null | undefined): string// 反序列化ISendable对象parse(text: string, reviver?: Transformer, options?: ParseOptions): ISendable | null

parse函数还有两个可选参数:reviver、options。含义与定义介绍如下:

  • reviver?: Transformer

转换函数,传入该参数,可以用来修改解析生成的原始值。默认值是undefined。(目前只支持传入undefined)。Transformer类型定义如下:​​​​​​​

// this:在解析的键值对所属的对象。key:属性名。value: 在解析的键值对d的值type Transformer = (this: ISendable, key: string, value: ISendable | undefined | null) => ISendable | undefined | null
  • options?: ParseOptions

解析的配置,传入该参数,可以用来控制解析生成的结果类型。默认值是undefined。ParseOptions类型定义如下:​​​​​​​

struct ParseOptions {  bigIntMode: BigIntMode; // 定义处理BigInt的模式。  parseReturnType: ParseReturnType; // 定义解析结果的返回类型。}// 定义处理BigInt的模式枚举enum BigIntMode {  DEFAULT = 0; // 不支持BigInt。  PARSE_AS_BIGINT = 1; // 当整数小于-(2^53-1)或大于(2^53-1)时,解析为BigInt。  ALWAYS_PARSE_AS_BIGINT = 2; // 所有整数都解析为BigInt。}enum ParseReturnType {  OBJECT = 0; // 返回Sendable Object对象。}

2、Sendable对象冻结

Sendable对象支持冻结操作,冻结后的对象变成只读对象,不能增删改属性,因此在多个并发实例间访问均不需要加锁,可以通过调用Object.freeze接口冻结对象。

使用示例如下:

👉🏻 step 1: 供ts文件封装Object.freeze方法。​​​​​​​

// helper.tsexport function freezeObj(obj: any) {  Object.freeze(obj);}

👉🏻 step 2: 通过调用freeze方法冻结对象,并将对象发送给子线程。​​​​​​​

// Index.etsimport { freezeObj } from './helper';import { worker } from '@kit.ArkTS';@Sendableexport class GlobalConfig {  // 一些配置属性与方法  init() {    // 初始化相关逻辑    freezeObj(this); // 初始化完成后冻结当前对象  }}@Entry@Componentstruct Index {  build() {    Column() {      Text("Sendable freezeObj Test")        .id('HelloWorld')        .fontSize(50)        .fontWeight(FontWeight.Bold)        .onClick(() => {          let gConifg = new GlobalConfig();          gConifg.init();          const workerInstance = new worker.ThreadWorker('entry/ets/workers/Worker.ets', { name: "Worker1" });          workerInstance.postMessage(gConifg);        })    }    .height('100%')    .width('100%')  }}

👉🏻 step 3: 子线程不加锁直接操作对象。​​​​​​​

// Worker.etsimport { ErrorEvent, MessageEvents, ThreadWorkerGlobalScope, worker } from '@kit.ArkTS';import { GlobalConfig } from '../pages/Index';const workerPort: ThreadWorkerGlobalScope = worker.workerPort;workerPort.onmessage = (e: MessageEvents) => {  let gConfig: GlobalConfig = e.data;  // 使用gConfig对象}


http://www.ppmy.cn/devtools/137375.html

相关文章

通用网络安全设备之【防火墙】

概念: 防火墙(Firewall),也称防护墙,它是一种位于内部网络与外部网络之间的网络安全防护系统,是一种隔离技术,允许或是限制传输的数据通过。 基于 TCP/IP 协议,主要分为主机型防火…

XSS 与 CSRF 记录

文章目录 前端容易遭受的攻击及解决方案XSS(跨站脚本攻击)CSRF(跨站请求伪造)点击劫持 解决方案实例场景还原XSS(跨站脚本攻击)防范案例CSRF(跨站请求伪造)防范案例点击劫持防范案例…

手搓一个不用中间件的分表策略

场景:针对一些特别的项目,不用中间件,以月为维度进行分表,代码详细设计方案 1. 定义分片策略 首先,定义一个分片策略类,用于决定数据存储在哪个分表中 import java.time.LocalDate; import java.time.fo…

书生大模型实战营第四期-入门岛-2. Python关卡任务

书生大模型实战营第四期-入门岛-2. Python关卡任务 书生大模型实战营-第四期 闯关手册:https://github.com/InternLM/Tutorial/blob/camp4/docs/L0/Python/task.md 任务类型任务内容预计耗时闯关任务Leetcode 383(笔记中提交代码与leetcode提交通过截图)20mins闯…

一个专为云原生环境设计的高性能分布式文件系统

大家好,今天给大家分享一款开源创新的分布式 POSIX 文件系统JuiceFS,旨在解决海量云存储与各类应用平台(如大数据、机器学习、人工智能等)之间高效对接的问题。 项目介绍 JuiceFS 是一款面向云原生设计的高性能分布式文件系统&am…

在Hadoop上实现分布式深度学习

在Hadoop上实现分布式深度学习 引言 随着大数据和深度学习的快速发展,分布式深度学习已成为当前研究和应用领域的热点。Hadoop作为一个广泛使用的分布式计算框架,在存储和处理大规模数据集方面表现出色,成为实现分布式深度学习的理想选择。…

AI时代的PPT革命:智能生成PPT工具为何备受青睐?

在日常工作和学习中,PPT是我们不可或缺的表达工具。制作一份精美的PPT常常需要耗费数小时,甚至几天的时间。从选择主题到调整排版,琐碎的细节让人筋疲力尽。但现在一种名为“AI生成PPT”的技术正悄然崛起,彻底颠覆了传统PPT制作的…

C语言学习 12(指针学习1)

一.内存和地址 1.内存 在讲内存和地址之前,我们想有个⽣活中的案例: 假设有⼀栋宿舍楼,把你放在楼⾥,楼上有100个房间,但是房间没有编号,你的⼀个朋友来找你玩,如果想找到你,就得挨…