Sendable对象简介

在传统JS引擎中,要优化对象的并发通信开销,唯一的方法是将实现下沉到Native侧,通过Transferable对象的转移或共享来降低开销。然而,开发者仍有大量对象并发通信的需求,这个问题在业界JS引擎中尚未解决。

ArkTS提供了Sendable对象类型,在并发通信时支持通过引用传递来解决上述问题。

Sendable对象可共享,跨线程前后指向同一个JS对象。如果包含JS或Native内容,可以直接共享。如果底层是Native实现,则需要确保线程安全性。通信过程如下图所示:

sendable

与其它ArkTS数据对象不同,符合Sendable协议的数据对象在运行时应为类型固定的对象。

当多个并发实例尝试同时更新Sendable数据时,会发生数据竞争,例如ArkTS共享容器的多线程操作。因此,ArkTS提供异步锁机制来避免不同并发实例间的数据竞争,并提供了异步等待机制来控制多线程处理数据的时序。同时,还可以通过对象冻结接口将对象冻结为只读,从而避免数据竞争。

Sendable对象提供了并发实例间高效的通信能力,即引用传递,适用于开发者自定义大对象需要线程间通信的场景,例如子线程读取数据库数据并返回给宿主线程,具体代码实现可参考跨并发实例传输大数据场景

基础概念

Sendable协议

Sendable协议定义了ArkTS的可共享对象体系及其规格约束。符合Sendable协议的数据(以下简称Sendable数据)可以在ArkTS并发实例间传递。

默认情况下,Sendable数据在ArkTS并发实例间(包括UI主线程、TaskPool线程、Worker线程)传递时采用引用传递。ArkTS还支持在这些实例间对Sendable数据进行拷贝传递。

ISendable

在ArkTS语言基础库@arkts.lang中引入了interface ISendable,没有任何方法或属性。ISendable是所有Sendable类型(除了null和undefined)的父类型。ISendable主要用于开发者自定义Sendable数据结构的场景中。类装饰器@Sendable装饰器是implement ISendable的语法糖。

Sendable class

说明:

从API version 11开始,支持使用@Sendable装饰器校验Sendable class。

Sendable class需同时满足以下两个规则:

  1. 针对API version 22以前的工程,当且仅当被标注了@Sendable装饰器。从API version 22开始,Sendable class除了必须标注@Sendable装饰器之外,开发者可根据需要在Sendable class上叠加使用其他自定义装饰器,具体操作可参考在Sendable class上叠加其他自定义装饰器

  2. 需满足Sendable约束,详情可查Sendable使用规则

Sendable function

说明:

  • 从API version 12开始,支持使用@Sendable装饰器校验Sendable function。

  • 针对API version 12的工程,开发者使用@Sendable装饰器校验Sendable function时,需在工程中配置"compatibleSdkVersionStage": "beta3",否则其Sendable特性将不生效。参考build-profile.json5配置文件说明

  • 针对API version大于12的工程,可直接使用@Sendable装饰器校验Sendable function,无需再进行其他配置。

Sendable function需同时满足以下两个规则:

  1. 当且仅当被标注了@Sendable装饰器

  2. 需满足Sendable约束,具体可参考Sendable使用规则

Sendable interface

Sendable interface需同时满足以下两个规则:

  1. 当且仅当是ISendable或者继承了ISendable。

  2. 需满足Sendable约束,具体可参考Sendable使用规则

Sendable支持的数据类型

说明:

  • JS内置对象在并发实例间传递时遵循结构化克隆算法,跨线程行为是拷贝传递。因此,JS内置对象的实例不是Sendable类型。

  • 对象字面量和数组字面量在并发实例间传递时遵循结构化克隆算法,跨线程行为是拷贝传递。因此,对象字面量和数组字面量不是Sendable类型。

Sendable支持const enum类型使用示例:

// Test.ets
export const enum ModelState {
  ACTIVE,
  INACTIVE
}
// Index.ets
import { taskpool } from "@kit.ArkTS";
import { ModelState } from "./Test";

@Sendable
class Model {
  state: ModelState = ModelState.ACTIVE;

  getState() {
    console.info("model state is " + this.state);
  }

  setState(state: ModelState) {
    this.state = state;
  }
}

@Concurrent
function setModelState(model: Model) {
  model.setState(ModelState.INACTIVE);
  model.getState();
}

@Entry
@Component
struct Index {
  @State message: string = 'Hello World';
  @State num: number = 0;

  build() {
    RelativeContainer() {
      Text(this.message)
        .id('HelloWorld')
        .fontSize(50)
        .fontWeight(FontWeight.Bold)
        .alignRules({
          center: { anchor: '__container__', align: VerticalAlign.Center },
          middle: { anchor: '__container__', align: HorizontalAlign.Center }
        })
        .onClick(async () => {
          let model = new Model();
          model.getState();
          let task = new taskpool.Task(setModelState, model);
          await taskpool.execute(task);
        })
    }
    .height('100%')
    .width('100%')
  }
}

Sendable的实现原理

为了实现Sendable数据在不同并发实例间的引用传递,Sendable共享对象分配在共享堆中,实现跨并发实例的内存共享。

共享堆(SharedHeap)是进程级别的堆空间,与虚拟机本地堆(LocalHeap)不同,LocalHeap仅限单个并发实例访问,而SharedHeap可被所有线程访问。Sendable对象的跨线程行为为引用传递,因此,一个Sendable对象可能被多个并发实例引用。判断该Sendable对象是否存活,取决于所有并发实例是否存在对此Sendable对象的引用。

SharedHeap与LocalHeap关系图

zh-cn_image_0000002001521153

各个并发实例的LocalHeap是隔离的。SharedHeap是进程级别的堆,可以被所有并发实例共享,但SharedHeap不能引用LocalHeap中的对象。

@Sendable装饰器

声明并校验Sendable class和Sendable function。

@Sendable装饰器 说明
装饰器参数 无。
使用场景限制 仅支持在Stage模型的.ets文件中使用。
装饰的函数类型限制 仅支持装饰普通function和Async function类型。
装饰的类继承关系限制 Sendable class只能继承Sendable class,普通Class不可继承Sendable class。
装饰的对象内的属性类型限制 1. 支持string、number、boolean、bigint、null、undefined、const enum、Sendable class、collections容器集、ArkTSUtils.locks.AsyncLock、ArkTSUtils.SendableLruCache、ArkTSUtils.locks.ConditionVariable以及自定义的Sendable函数类型。
2. 禁止使用闭包变量,定义在顶层的Sendable class和Sendable function除外。
3. 不支持通过#定义私有属性,需用private。
4. 不支持计算属性。
装饰的对象内的属性的其他限制 1. 成员属性必须显式初始化,不能使用感叹号。
2. 不支持增加或删除属性,允许修改属性,修改前后属性的类型必须一致,不支持修改方法。
装饰的函数或类对象内的方法参数限制 允许使用local变量、入参和通过import引入的变量。禁止使用闭包变量,但定义在顶层的Sendable class和Sendable function除外。从API version 18开始,支持访问本文件导出的变量。
适用场景 1. 在TaskPool或Worker中使用类方法或Sendable函数。
2. 传输对象数据量较大的场景。序列化耗时会随着数据量增大而增大,使用Sendable对数据进行改造后,传输100KB数据效率提升约20倍,传输1M数据效率提升约100倍。

装饰器修饰Class使用示例:

@Sendable
class SendableTestClass {
  desc: string = "sendable: this is SendableTestClass ";
  num: number = 5;
  printName() {
    console.info("sendable: SendableTestClass desc is: " + this.desc);
  }
  getNum(): number {
    return this.num;
  }
}

装饰器修饰Function使用示例:

@Sendable
type SendableFuncType = () => void;

@Sendable
class TopLevelSendableClass {
  num: number = 1;
  PrintNum() {
    console.info("Top level sendable class");
  }
}

@Sendable
function TopLevelSendableFunction() {
  console.info("Top level sendable function");
}

@Sendable
function SendableTestFunction() {
  const topClass = new TopLevelSendableClass(); // 顶层sendable class
  topClass.PrintNum();
  TopLevelSendableFunction(); // 顶层sendable function
  console.info("Sendable test function");
}

@Sendable
class SendableTestClass {
  constructor(func: SendableFuncType) {
    this.callback = func;
  }
  callback: SendableFuncType; // 顶层sendable function

  CallSendableFunc() {
    SendableTestFunction(); // 顶层sendable function
  }
}

let sendableClass = new SendableTestClass(SendableTestFunction);
sendableClass.callback();
sendableClass.CallSendableFunc();