harmony 鸿蒙@ohos.taskpool(启动任务池)
@ohos.taskpool(启动任务池)
任务池(taskpool)作用是为应用程序提供一个多线程的运行环境,降低整体资源的消耗、提高系统的整体性能,且您无需关心线程实例的生命周期。您可以使用任务池API创建后台任务(Task),并对所创建的任务进行如任务执行、任务取消的操作。理论上您可以使用任务池API创建数量不受限制的任务,但是出于内存因素不建议您这样做。此外,不建议您在任务中执行阻塞操作,特别是无限期阻塞操作,长时间的阻塞操作占据工作线程,可能会阻塞其他任务调度,影响您的应用性能。
您所创建的同一优先级任务的执行顺序可以由您决定,任务真实执行的顺序与您调用任务池API提供的任务执行接口顺序一致。任务默认优先级是MEDIUM。
当同一时间待执行的任务数量大于任务池工作线程数量,任务池会根据负载均衡机制进行扩容,增加工作线程数量,减少整体等待时长。同样,当执行的任务数量减少,工作线程数量大于执行任务数量,部分工作线程处于空闲状态,任务池会根据负载均衡机制进行缩容,减少工作线程数量。
任务池API以数字形式返回错误码。有关各个错误码的更多信息,请参阅文档语言基础类库错误码。
说明:
本模块首批接口从API version 9 开始支持。后续版本的新增接口,采用上角标单独标记接口的起始版本。
导入模块
import taskpool from '@ohos.taskpool';
taskpool.execute
execute(func: Function, …args: unknown[]): Promise<unknown>
将待执行的函数放入taskpool内部任务队列等待,等待分发到工作线程执行。当前执行模式不可取消任务。
系统能力: SystemCapability.Utils.Lang
参数:
参数名 | 类型 | 必填 | 说明 |
---|---|---|---|
func | Function | 是 | 执行的逻辑需要传入函数,支持的函数返回值类型请查序列化支持类型。 |
args | unknown[] | 否 | 执行逻辑的函数所需要的参数,支持的参数类型请查序列化支持类型。默认值为undefined。 |
返回值:
类型 | 说明 |
---|---|
Promise<unknown> | execute是异步方法,返回Promise对象。 |
错误码:
以下错误码的详细介绍请参见语言基础类库错误码。
错误码ID | 错误信息 |
---|---|
10200003 | Worker initialization failure. |
10200006 | An exception occurred during serialization. |
10200014 | The function is not mark as concurrent. |
示例:
@Concurrent
function printArgs(args: number): number {
console.log("printArgs: " + args);
return args;
}
taskpool.execute(printArgs, 100).then((value: number) => { // 100: test number
console.log("taskpool result: " + value);
});
taskpool.execute
execute(task: Task, priority?: Priority): Promise<unknown>
将创建好的任务放入taskpool内部任务队列等待,等待分发到工作线程执行。当前执行模式可尝试调用cancel进行任务取消。
系统能力: SystemCapability.Utils.Lang
参数:
参数名 | 类型 | 必填 | 说明 |
---|---|---|---|
task | Task | 是 | 需要在任务池中执行的任务。 |
priority | Priority | 否 | 等待执行的任务的优先级,该参数默认值为taskpool.Priority.MEDIUM。 |
返回值:
类型 | 说明 |
---|---|
Promise<unknown> | 返回Promise对象。 |
错误码:
以下错误码的详细介绍请参见语言基础类库错误码。
错误码ID | 错误信息 |
---|---|
10200003 | Worker initialization failure. |
10200006 | An exception occurred during serialization. |
10200014 | The function is not mark as concurrent. |
示例:
@Concurrent
function printArgs(args: number): number {
console.log("printArgs: " + args);
return args;
}
let task: taskpool.Task = new taskpool.Task(printArgs, 100); // 100: test number
taskpool.execute(task).then((value: number) => {
console.log("taskpool result: " + value);
});
taskpool.execute10+
execute(group: TaskGroup, priority?: Priority): Promise
将创建好的任务组放入taskpool内部任务队列等待,等待分发到工作线程执行。
系统能力: SystemCapability.Utils.Lang
参数:
参数名 | 类型 | 必填 | 说明 |
---|---|---|---|
group | TaskGroup | 是 | 需要在任务池中执行的任务组。 |
priority | Priority | 否 | 等待执行的任务组的优先级,该参数默认值为taskpool.Priority.MEDIUM。 |
返回值:
类型 | 说明 |
---|---|
Promise<unknown[]> | execute是异步方法,返回Promise对象。 |
错误码:
以下错误码的详细介绍请参见语言基础类库错误码。
错误码ID | 错误信息 |
---|---|
10200006 | An exception occurred during serialization. |
示例:
@Concurrent
function printArgs(args: number): number {
console.log("printArgs: " + args);
return args;
}
let taskGroup1: taskpool.TaskGroup = new taskpool.TaskGroup();
taskGroup1.addTask(printArgs, 10); // 10: test number
taskGroup1.addTask(printArgs, 20); // 20: test number
taskGroup1.addTask(printArgs, 30); // 30: test number
let taskGroup2: taskpool.TaskGroup = new taskpool.TaskGroup();
let task1: taskpool.Task = new taskpool.Task(printArgs, 100); // 100: test number
let task2: taskpool.Task = new taskpool.Task(printArgs, 200); // 200: test number
let task3: taskpool.Task = new taskpool.Task(printArgs, 300); // 300: test number
taskGroup2.addTask(task1);
taskGroup2.addTask(task2);
taskGroup2.addTask(task3);
taskpool.execute(taskGroup1).then((res: Array<number>) => {
console.info("taskpool execute res is:" + res);
});
taskpool.execute(taskGroup2).then((res: Array<number>) => {
console.info("taskpool execute res is:" + res);
});
taskpool.cancel
cancel(task: Task): void
取消任务池中的任务。
系统能力: SystemCapability.Utils.Lang
参数:
参数名 | 类型 | 必填 | 说明 |
---|---|---|---|
task | Task | 是 | 需要取消执行的任务。 |
错误码:
以下错误码的详细介绍请参见语言基础类库错误码。
错误码ID | 错误信息 |
---|---|
10200015 | The task does not exist when it is canceled. |
10200016 | The task is executing when it is canceled. |
从API version10开始,此接口调用时不再涉及上报错误码10200016。
正在执行的任务取消示例:
@Concurrent
function inspectStatus(arg: number): number {
// 第一时间检查取消并回复
if (taskpool.Task.isCanceled()) {
console.log("task has been canceled before 2s sleep.");
return arg + 2;
}
// 2s sleep
let t: number = Date.now();
while (Date.now() - t < 2000) {
continue;
}
// 第二次检查取消并作出响应
if (taskpool.Task.isCanceled()) {
console.log("task has been canceled after 2s sleep.");
return arg + 3;
}
return arg + 1;
}
let task1: taskpool.Task = new taskpool.Task(inspectStatus, 100); // 100: test number
let task2: taskpool.Task = new taskpool.Task(inspectStatus, 200); // 200: test number
let task3: taskpool.Task = new taskpool.Task(inspectStatus, 300); // 300: test number
let task4: taskpool.Task = new taskpool.Task(inspectStatus, 400); // 400: test number
let task5: taskpool.Task = new taskpool.Task(inspectStatus, 500); // 500: test number
let task6: taskpool.Task = new taskpool.Task(inspectStatus, 600); // 600: test number
taskpool.execute(task1).then((res: number)=>{
console.log("taskpool test result: " + res);
});
taskpool.execute(task2);
taskpool.execute(task3);
taskpool.execute(task4);
taskpool.execute(task5);
taskpool.execute(task6);
// 1s后取消task
setTimeout(()=>{
taskpool.cancel(task1);
}, 1000);
taskpool.cancel10+
cancel(group: TaskGroup): void
取消任务池中的任务组。
系统能力: SystemCapability.Utils.Lang
参数:
参数名 | 类型 | 必填 | 说明 |
---|---|---|---|
group | TaskGroup | 是 | 需要取消执行的任务组。 |
错误码:
以下错误码的详细介绍请参见语言基础类库错误码。
错误码ID | 错误信息 |
---|---|
10200018 | The task group does not exist when it is canceled. |
示例:
@Concurrent
function printArgs(args: number): number {
let t: number = Date.now();
while (Date.now() - t < 2000) {
continue;
}
console.log("printArgs: " + args);
return args;
}
let taskGroup1: taskpool.TaskGroup = new taskpool.TaskGroup();
taskGroup1.addTask(printArgs, 10); // 10: test number
let taskGroup2: taskpool.TaskGroup = new taskpool.TaskGroup();
taskGroup2.addTask(printArgs, 100); // 100: test number
taskpool.execute(taskGroup1).then((res: Array<number>)=>{
console.info("taskGroup1 res is:" + res);
});
taskpool.execute(taskGroup2).then((res: Array<number>)=>{
console.info("taskGroup2 res is:" + res);
});
setTimeout(()=>{
try {
taskpool.cancel(taskGroup2);
} catch (e) {
console.log("taskGroup.cancel occur error:" + e);
}
}, 1000);
taskpool.getTaskPoolInfo10+
getTaskPoolInfo(): TaskPoolInfo
获取任务池内部信息。
系统能力: SystemCapability.Utils.Lang
返回值:
类型 | 说明 |
---|---|
TaskPoolInfo | 任务池的内部信息。 |
示例:
let taskpoolInfo: taskpool.TaskPoolInfo = taskpool.getTaskPoolInfo();
Priority
表示所创建任务(Task)的优先级。
系统能力: SystemCapability.Utils.Lang
名称 | 值 | 说明 |
---|---|---|
HIGH | 0 | 任务为高优先级。 |
MEDIUM | 1 | 任务为中优先级。 |
LOW | 2 | 任务为低优先级。 |
示例:
@Concurrent
function printArgs(args: number): number {
console.log("printArgs: " + args);
return args;
}
let task: taskpool.Task = new taskpool.Task(printArgs, 100); // 100: test number
let highCount = 0;
let mediumCount = 0;
let lowCount = 0;
let allCount = 100;
for (let i: number = 0; i < allCount; i++) {
taskpool.execute(task, taskpool.Priority.LOW).then((res: number) => {
lowCount++;
console.log("taskpool lowCount is :" + lowCount);
});
taskpool.execute(task, taskpool.Priority.MEDIUM).then((res: number) => {
mediumCount++;
console.log("taskpool mediumCount is :" + mediumCount);
});
taskpool.execute(task, taskpool.Priority.HIGH).then((res: number) => {
highCount++;
console.log("taskpool highCount is :" + highCount);
});
}
Task
表示任务。使用constructor方法构造Task。
constructor
constructor(func: Function, …args: unknown[])
Task的构造函数。
系统能力: SystemCapability.Utils.Lang
参数:
参数名 | 类型 | 必填 | 说明 |
---|---|---|---|
func | Function | 是 | 任务执行需要传入函数,支持的函数返回值类型请查序列化支持类型。 |
args | unknown[] | 否 | 任务执行传入函数的参数,支持的参数类型请查序列化支持类型。默认值为undefined。 |
错误码:
以下错误码的详细介绍请参见语言基础类库错误码。
错误码ID | 错误信息 |
---|---|
10200014 | The function is not mark as concurrent. |
示例:
@Concurrent
function printArgs(args: number): number {
console.log("printArgs: " + args);
return args;
}
let task: taskpool.Task = new taskpool.Task(printArgs, "this is my first Task");
isCanceled10+
static isCanceled(): boolean
检查当前正在运行的任务是否已取消。使用该方法前需要先构造Task。
系统能力: SystemCapability.Utils.Lang
返回值:
类型 | 说明 |
---|---|
boolean | 如果当前正在运行的任务被取消返回true,未被取消返回false。 |
示例:
@Concurrent
function inspectStatus(arg: number): number {
// do something
if (taskpool.Task.isCanceled()) {
console.log("task has been canceled.");
// do something
return arg + 1;
}
// do something
return arg;
}
说明:
isCanceled方法需要和taskpool.cancel方法搭配使用,如果不调用cancel方法,isCanceled方法默认返回false。
示例:
@Concurrent
function inspectStatus(arg: number): number {
// 第一时间检查取消并回复
if (taskpool.Task.isCanceled()) {
console.log("task has been canceled before 2s sleep.");
return arg + 2;
}
// 延时2s
let t: number = Date.now();
while (Date.now() - t < 2000) {
continue;
}
// 第二次检查取消并作出响应
if (taskpool.Task.isCanceled()) {
console.log("task has been canceled after 2s sleep.");
return arg + 3;
}
return arg + 1;
}
let task: taskpool.Task = new taskpool.Task(inspectStatus, 100); // 100: test number
taskpool.execute(task).then((res: number)=>{
console.log("taskpool test result: " + res);
}).catch((err: string) => {
console.log("taskpool test occur error: " + err);
});
// 不调用cancel,isCanceled()默认返回false,task执行的结果为101
setTransferList10+
setTransferList(transfer?: ArrayBuffer[]): void
设置任务的传输列表。使用该方法前需要先构造Task。
说明:
此接口可以设置任务池中ArrayBuffer的transfer列表,transfer列表中的ArrayBuffer对象在传输时不会复制buffer内容到工作线程而是转移buffer控制权至工作线程,传输后当前的ArrayBuffer失效。
系统能力: SystemCapability.Utils.Lang
参数:
参数名 | 类型 | 必填 | 说明 |
---|---|---|---|
transfer | ArrayBuffer[] | 否 | 可传输对象是ArrayBuffer的实例对象,默认为空数组。 |
示例:
let buffer: ArrayBuffer = new ArrayBuffer(8);
let view: Uint8Array = new Uint8Array(buffer);
let buffer1: ArrayBuffer = new ArrayBuffer(16);
let view1: Uint8Array = new Uint8Array(buffer1);
console.info("testTransfer view byteLength: " + view.byteLength);
console.info("testTransfer view1 byteLength: " + view1.byteLength);
@Concurrent
function testTransfer(arg1: ArrayBuffer, arg2: ArrayBuffer): number {
console.info("testTransfer arg1 byteLength: " + arg1.byteLength);
console.info("testTransfer arg2 byteLength: " + arg2.byteLength);
return 100;
}
let task: taskpool.Task = new taskpool.Task(testTransfer, view, view1);
task.setTransferList([view.buffer, view1.buffer]);
taskpool.execute(task).then((res: number)=>{
console.info("test result: " + res);
}).catch((e: string)=>{
console.error("test catch: " + e);
})
console.info("testTransfer view byteLength: " + view.byteLength);
console.info("testTransfer view1 byteLength: " + view1.byteLength);
属性
系统能力: SystemCapability.Utils.Lang
名称 | 类型 | 可读 | 可写 | 说明 |
---|---|---|---|---|
function | Function | 是 | 是 | 创建任务时需要传入的函数,支持的函数返回值类型请查序列化支持类型。 |
arguments | unknown[] | 是 | 是 | 创建任务传入函数所需的参数,支持的参数类型请查序列化支持类型。 |
TaskGroup10+
表示任务组。使用constructor方法构造TaskGroup。
constructor10+
constructor()
TaskGroup的构造函数。
系统能力: SystemCapability.Utils.Lang
示例:
let taskGroup = new taskpool.TaskGroup();
addTask10+
addTask(func: Function, …args: unknown[]): void
将待执行的函数添加到任务组中。使用该方法前需要先构造TaskGroup。
系统能力: SystemCapability.Utils.Lang
参数:
参数名 | 类型 | 必填 | 说明 |
---|---|---|---|
func | Function | 是 | 任务执行需要传入函数,支持的函数返回值类型请查序列化支持类型。 |
args | unknown[] | 否 | 任务执行函数所需要的参数,支持的参数类型请查序列化支持类型。默认值为undefined。 |
错误码:
以下错误码的详细介绍请参见语言基础类库错误码。
错误码ID | 错误信息 |
---|---|
10200014 | The function is not mark as concurrent. |
示例:
@Concurrent
function printArgs(args: number): number {
console.log("printArgs: " + args);
return args;
}
let taskGroup: taskpool.TaskGroup = new taskpool.TaskGroup();
taskGroup.addTask(printArgs, 100); // 100: test number
addTask10+
addTask(task: Task): void
将创建好的任务添加到任务组中。使用该方法前需要先构造TaskGroup。
系统能力: SystemCapability.Utils.Lang
参数:
参数名 | 类型 | 必填 | 说明 |
---|---|---|---|
task | Task | 是 | 需要添加到任务组中的任务。 |
错误码:
以下错误码的详细介绍请参见语言基础类库错误码。
错误码ID | 错误信息 |
---|---|
10200014 | The function is not mark as concurrent. |
示例:
@Concurrent
function printArgs(args: number): number {
console.log("printArgs: " + args);
return args;
}
let taskGroup: taskpool.TaskGroup = new taskpool.TaskGroup();
let task: taskpool.Task = new taskpool.Task(printArgs, 200); // 200: test number
taskGroup.addTask(task);
State10+
表示任务(Task)状态的枚举。
系统能力: SystemCapability.Utils.Lang
名称 | 值 | 说明 |
---|---|---|
WAITING | 1 | 任务正在等待。 |
RUNNING | 2 | 任务正在执行。 |
CANCELED | 3 | 任务已被取消。 |
TaskInfo10+
任务的内部信息。
系统能力: SystemCapability.Utils.Lang
属性
系统能力: SystemCapability.Utils.Lang
名称 | 类型 | 可读 | 可写 | 说明 |
---|---|---|---|---|
taskId | number | 是 | 否 | 任务的ID。 |
state | State | 是 | 否 | 任务的状态。 |
duration | number | 是 | 否 | 任务执行至当前所用的时间,单位为ms。当返回为0时,表示任务未执行;返回为空时,表示没有任务执行 |
ThreadInfo10+
工作线程的内部信息。
系统能力: SystemCapability.Utils.Lang
属性
系统能力: SystemCapability.Utils.Lang
名称 | 类型 | 可读 | 可写 | 说明 |
---|---|---|---|---|
tid | number | 是 | 否 | 工作线程的标识符。返回为空时,代表没有任务执行。 |
taskIds | number[] | 是 | 否 | 在当前线程上运行的任务id列表。返回为空时,代表没有任务执行。 |
priority | Priority | 是 | 否 | 当前线程的优先级。返回为空时,代表没有任务执行。 |
TaskPoolInfo10+
任务池的内部信息。
系统能力: SystemCapability.Utils.Lang
属性
系统能力: SystemCapability.Utils.Lang
名称 | 类型 | 可读 | 可写 | 说明 |
---|---|---|---|---|
threadInfos | ThreadInfo[] | 是 | 否 | 工作线程的内部信息。 |
taskInfos | TaskInfo[] | 是 | 否 | 任务的内部信息。 |
其他说明
序列化支持类型
序列化支持类型包括:All Primitive Type(不包括symbol)、Date、String、RegExp、Array、Map、Set、Object、ArrayBuffer、TypedArray。
简单使用
示例一
// 支持普通函数、引用入参传递
@Concurrent
function printArgs(args: number): number {
console.log("func: " + args);
return args;
}
async function taskpoolExecute(): Promise<void> {
// taskpool.execute(task)
let task: taskpool.Task = new taskpool.Task(printArgs, "create task, then execute");
console.log("taskpool.execute(task) result: " + await taskpool.execute(task));
// taskpool.execute(function)
console.log("taskpool.execute(function) result: " + await taskpool.execute(printArgs, "execute task by func"));
}
taskpoolExecute();
示例二
// b.ets
export let c: string = "hello";
// 引用import变量
// a.ets(与b.ets位于同一目录中)
import { c } from "./b";
@Concurrent
function printArgs(a: string): string {
console.log(a);
console.log(c);
return a;
}
async function taskpoolExecute(): Promise<void> {
// taskpool.execute(task)
let task: taskpool.Task = new taskpool.Task(printArgs, "create task, then execute");
console.log("taskpool.execute(task) result: " + await taskpool.execute(task));
// taskpool.execute(function)
console.log("taskpool.execute(function) result: " + await taskpool.execute(printArgs, "execute task by func"));
}
taskpoolExecute();
示例三
// 支持async函数
@Concurrent
async function delayExcute(): Promise<Object> {
let ret = await Promise.all<Object>([
new Promise<Object>(resolve => setTimeout(resolve, 1000, "resolved"))
]);
return ret;
}
async function taskpoolExecute(): Promise<void> {
taskpool.execute(delayExcute).then((result: string) => {
console.log("taskPoolTest task result: " + result);
}).catch((err: string) => {
console.log("taskpool test occur error: " + err);
});
}
taskpoolExecute();
示例四
// c.ets
@Concurrent
function strSort(inPutArr: Array<string>): Array<string> {
let newArr = inPutArr.sort();
return newArr;
}
export async function func1(): Promise<void> {
console.log("taskpoolTest start");
let strArray: Array<string> = ['c test string', 'b test string', 'a test string'];
let task: taskpool.Task = new taskpool.Task(strSort, strArray);
console.log("func1 result:" + await taskpool.execute(task));
}
export async function func2(): Promise<void> {
console.log("taskpoolTest2 start");
let strArray: Array<string> = ['c test string', 'b test string', 'a test string'];
taskpool.execute(strSort, strArray).then((result: Array<string>) => {
console.log("func2 result: " + result);
}).catch((err: string) => {
console.log("taskpool test occur error: " + err);
});
}
// a.ets(与c.ets在同一目录中)
import { func1, func2 } from "./c";
func1();
func2();
示例五
// 任务取消成功
@Concurrent
function inspectStatus(arg: number): number {
// 第一时间检查取消并回复
if (taskpool.Task.isCanceled()) {
console.log("task has been canceled before 2s sleep.");
return arg + 2;
}
// 2s sleep
let t: number = Date.now();
while (Date.now() - t < 2000) {
continue;
}
// 第二次检查取消并作出响应
if (taskpool.Task.isCanceled()) {
console.log("task has been canceled after 2s sleep.");
return arg + 3;
}
return arg + 1;
}
async function taskpoolCancel(): Promise<void> {
let task: taskpool.Task = new taskpool.Task(inspectStatus, 100); // 100: test number
taskpool.execute(task).then((res: number)=>{
console.log("taskpool test result: " + res);
}).catch((err: string) => {
console.log("taskpool test occur error: " + err);
});
// 1s后取消task
setTimeout(()=>{
taskpool.cancel(task);}, 1000);
}
taskpoolCancel();
示例六
// 已执行的任务取消失败
@Concurrent
function inspectStatus(arg: number): number {
// 第一时间检查取消并回复
if (taskpool.Task.isCanceled()) {
return arg + 2;
}
// 延时2s
let t: number = Date.now();
while (Date.now() - t < 500) {
continue;
}
// 第二次检查取消并作出响应
if (taskpool.Task.isCanceled()) {
return arg + 3;
}
return arg + 1;
}
async function taskpoolCancel(): Promise<void> {
let task: taskpool.Task = new taskpool.Task(inspectStatus, 100); // 100: test number
taskpool.execute(task).then((res: number)=>{
console.log("taskpool test result: " + res);
}).catch((err: string) => {
console.log("taskpool test occur error: " + err);
});
setTimeout(()=>{
try {
taskpool.cancel(task); // 任务已执行,取消失败
} catch (e) {
console.log("taskpool.cancel occur error:" + e);
}
}, 3000); // 延时3s,确保任务已执行
}
taskpoolCancel();
示例七
// 待执行的任务组取消成功
@Concurrent
function printArgs(args: number): number {
let t: number = Date.now();
while (Date.now() - t < 1000) {
continue;
}
console.log("printArgs: " + args);
return args;
}
async function taskpoolGroupCancelTest(): Promise<void> {
let taskGroup1: taskpool.TaskGroup = new taskpool.TaskGroup();
taskGroup1.addTask(printArgs, 10); // 10: test number
taskGroup1.addTask(printArgs, 20); // 20: test number
taskGroup1.addTask(printArgs, 30); // 30: test number
let taskGroup2: taskpool.TaskGroup = new taskpool.TaskGroup();
let task1: taskpool.Task = new taskpool.Task(printArgs, 100); // 100: test number
let task2: taskpool.Task = new taskpool.Task(printArgs, 200); // 200: test number
let task3: taskpool.Task = new taskpool.Task(printArgs, 300); // 300: test number
taskGroup2.addTask(task1);
taskGroup2.addTask(task2);
taskGroup2.addTask(task3);
taskpool.execute(taskGroup1).then((res: Array<number>) => {
console.info("taskpool execute res is:" + res);
}).catch((e: string) => {
console.error("taskpool execute error is:" + e);
});
taskpool.execute(taskGroup2).then((res: Array<number>) => {
console.info("taskpool execute res is:" + res);
}).catch((e: string) => {
console.error("taskpool execute error is:" + e);
});
taskpool.cancel(taskGroup2);
}
taskpoolGroupCancelTest()
示例八
// 分别创建执行100个高、中、低优先级的任务,查看其各项信息
@Concurrent
function delay(): void {
let start: number = new Date().getTime();
while (new Date().getTime() - start < 500) {
continue;
}
}
let highCount: number = 0;
let mediumCount: number = 0;
let lowCount: number = 0;
let allCount: number = 100;
for (let i = 0; i < allCount; i++) {
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).then(() => {
lowCount++;
}).catch((e: string) => {
console.error("low task error: " + e);
})
taskpool.execute(task2, taskpool.Priority.MEDIUM).then(() => {
mediumCount++;
}).catch((e: string) => {
console.error("medium task error: " + e);
})
taskpool.execute(task3, taskpool.Priority.HIGH).then(() => {
highCount++;
}).catch((e: string) => {
console.error("high task error: " + e);
})
}
let start: number = new Date().getTime();
while (new Date().getTime() - start < 1000) {
continue;
}
let taskpoolInfo: taskpool.TaskPoolInfo = taskpool.getTaskPoolInfo();
let tid: number = 0;
let taskIds: Array<number> = [];
let priority: number = 0;
let taskId: number = 0;
let state: number = 0;
let duration: number = 0;
let threadIS = Array.from(taskpoolInfo.threadInfos)
for(let threadInfo of threadIS) {
tid = threadInfo.tid;
if (threadInfo.taskIds != undefined && threadInfo.priority != undefined )
{
taskIds.length = threadInfo.taskIds.length;
priority = threadInfo.priority;
}
console.info("taskpool---tid is:" + tid + ", taskIds is:" + taskIds + ", priority is:" + priority);
}
let taskIS = Array.from(taskpoolInfo.taskInfos)
for(let taskInfo of taskIS) {
taskId = taskInfo.taskId;
state = taskInfo.state;
if (taskInfo.duration != undefined )
{
duration = taskInfo.duration;
}
console.info("taskpool---taskId is:" + taskId + ", state is:" + state + ", duration is:" + duration);
}
你可能感兴趣的鸿蒙文章
harmony 鸿蒙BundleStatusCallback
harmony 鸿蒙@ohos.bundle.innerBundleManager (innerBundleManager模块)
harmony 鸿蒙@ohos.distributedBundle (分布式包管理)
harmony 鸿蒙@ohos.bundle (Bundle模块)
harmony 鸿蒙@ohos.enterprise.EnterpriseAdminExtensionAbility (企业设备管理扩展能力)
- 所属分类: 后端技术
- 本文标签:
热门推荐
-
2、 - 优质文章
-
3、 gate.io
-
8、 golang
-
9、 openharmony
-
10、 Vue中input框自动聚焦