CommonLibrary Subsystem Changelog

cl.commonlibrary.1 Behavior for the Task Pool to Transfer Sendable Data Is Changed

Access Level

Other

Change Reason

The task pool is used to execute concurrent tasks. If Sendable data is directly returned in a call or the sendData API is called for data transmission, the default transmission mode of the Sendable data is changed from clone to shared. This change is because the data is seldom used after the task in the task pool is executed.

Change Impact

This change is a non-compatible change.

Before the change, when taskpool.Task.sendData of API version 11 is used to send or directly return Sendable data, one copy is made by default.

After the change, Sendable data is shared in this scenario. If the data is modified in the host thread, the subthread gets notified. However, the task pool is executed by task. There is a low probability that simultaneous operations are performed on the same object, and the impact of subsequent data changes on the task pool is controllable.

In the following code, the printed value may be 100 or changed to 200 by the subthread:

import { taskpool } from '@kit.ArkTS'
@Sendable
class A {
    num: number = 100
}
@Concurrent
async function foo(a: A) {
    taskpool.Task.sendData(a)
    a.num = 200
}
let a: A = new A()
let task = new taskpool.Task(foo, a)
task.onReceiveData((val: A) => {
    console.log("num: " + val.num)
})

Start API Level

API version 11

Change Since

OpenHarmony SDK 5.0.0.18

Key API/Component Changes

N/A

Adaptation Guide

If sendData is not executed in the task pool or the read and write operations on the same attribute are performed by two independent threads after data is returned, no adaptation is required.

If sendData is executed in the task pool or the host thread and its subthread read and write the same attribute after data is returned, a lock must be used (imported from @arkts.utils).

Current code:

import { taskpool } from '@kit.ArkTS'
@Sendable
class A {
    num: number = 100
}
@Concurrent
async function foo(a: A) {
    taskpool.Task.sendData(a)
    a.num = 200
}
let a: A = new A()
let task = new taskpool.Task(foo, a)
task.onReceiveData((val: A) => {
    console.log("num: " + val.num)
})

To ensure the thread safety of the num domain of class A, synchronization protection is required. The recommended code snippet is as follows:

import { taskpool } from '@kit.ArkTS'
@Sendable
class A {
    num: number = 100
    async setNum(num: number) {
        // add lock here
        this.num = num
    }
    async getNum(): Promise<number> {
        // add lock here
        return this.num
    }
}
@Concurrent
async function foo(a: A) {
    taskpool.Task.sendData(a)
    a.setNum(200)
}
let a: A = new A()
let task = new taskpool.Task(foo, a)
task.onReceiveData((val: A) => {
    console.log("num: " + val.getNum())
})

cl.commonlibrary.2 taskId in taskInfos Obtained by Calling taskpool.getTaskPoolInfo Is Changed from BigInt to Number

Access Level

Other

Change Reason

taskId of the number type is sufficient for use.

Change Impact

This change is a non-compatible change.

Before the change, the taskId type is BigInt.

After the change, the taskId type is number. taskId is a member of TaskInfo in the TaskPoolInfo class obtained through taskpool.getTaskPoolInfo. The change of the member type does not affect other attributes obtained using taskpool.getTaskPoolInfo. The change has little impact on developers.

Current code:

import { taskpool } from '@kit.ArkTS'

@Concurrent
function delay(): void {
  let start: number = new Date().getTime();
  while (new Date().getTime() - start < 500) {
    continue;
  }
}

let task1: taskpool.Task = new taskpool.Task(delay);
let task2: taskpool.Task = new taskpool.Task(delay);
let task3: taskpool.Task = new taskpool.Task(delay);
taskpool.execute(task1, taskpool.Priority.LOW)
taskpool.execute(task2, taskpool.Priority.MEDIUM)
taskpool.execute(task3, taskpool.Priority.HIGH)
let start: number = new Date().getTime();
while (new Date().getTime() - start < 1000) {
  continue;
}
let taskpoolInfo: taskpool.TaskPoolInfo = taskpool.getTaskPoolInfo();
let taskId: number = 0;
let taskIS = Array.from(taskpoolInfo.taskInfos)
for(let taskInfo of taskIS) {
  taskId = taskInfo.taskId;
  console.info("taskpool---taskId is:" + taskId);
}

Start API Level

API version 11

Change Since

OpenHarmony SDK 5.0.0.18

Key API/Component Changes

taskpool.getTaskPoolInfo

Adaptation Guide

Define the taskId type as number.

你可能感兴趣的鸿蒙文章

harmony 鸿蒙ArkCompiler Subsystem Changelog