任務池（taskpool）作用是為應用程序提供一個多線程的運行環(huán)境，降低整體資源的消耗、提高系統(tǒng)的整體性能，且您無需關心線程實例的生命周期。您可以使用任務池API創(chuàng)建后臺任務（Task），并對所創(chuàng)建的任務進行如任務執(zhí)行、任務取消的操作。理論上您可以使用任務池API創(chuàng)建數量不受限制的任務，但是出于內存因素不建議您這樣做。此外，不建議您在任務中執(zhí)行阻塞操作，特別是無限期阻塞操作，長時間的阻塞操作占據工作線程，可能會阻塞其他任務調度，影響您的應用性能。

您所創(chuàng)建的同一優(yōu)先級任務的執(zhí)行順序可以由您決定，任務真實執(zhí)行的順序與您調用任務池API提供的任務執(zhí)行接口順序一致。任務默認優(yōu)先級是MEDIUM。（任務優(yōu)先級機制暫未支持）

當同一時間待執(zhí)行的任務數量大于任務池工作線程數量，任務池會根據負載均衡機制進行擴容，增加工作線程數量，減少整體等待時長。同樣，當執(zhí)行的任務數量減少，工作線程數量大于執(zhí)行任務數量，部分工作線程處于空閑狀態(tài)，任務池會根據負載均衡機制進行縮容，減少工作線程數量。（負載均衡機制暫未支持）

任務池API以數字形式返回錯誤碼。有關各個錯誤碼的更多信息，請參閱文檔 鴻蒙開發(fā)指導文檔 ：[gitee.com/li-shizhen-skin/harmony-os/blob/master/README.md]

說明：
本模塊首批接口從API version 9 開始支持。后續(xù)版本的新增接口，采用上角標單獨標記接口的起始版本。

導入模塊

HarmonyOS與OpenHarmony鴻蒙文檔籽料：mau123789是v直接拿
import taskpool from '@ohos.taskpool';

taskpool.execute

execute(func: Function, ...args: unknown[]): Promise

將待執(zhí)行的函數放入taskpool內部任務隊列等待，等待分發(fā)到工作線程執(zhí)行。當前執(zhí)行模式不可取消任務。

系統(tǒng)能力： SystemCapability.Utils.Lang

參數：

返回值：

錯誤碼：

以下錯誤碼的詳細介紹請參見[語言基礎類庫錯誤碼]。

示例：

@Concurrent
function printArgs(args) {
    console.log("printArgs: " + args);
    return args;
}

async function taskpoolExecute() {
  let value = await taskpool.execute(printArgs, 100);
  console.log("taskpool result: " + value);
}

taskpoolExecute();

[](https://gitee.com/openharmony/docs/blob/OpenHarmony-3.2-Release/zh-cn/application-dev/reference/apis/js-apis-taskpool.md#taskpoolexecute-1)taskpool.execute

execute(task: Task, priority?: Priority): Promise

將創(chuàng)建好的任務放入taskpool內部任務隊列等待，等待分發(fā)到工作線程執(zhí)行。當前執(zhí)行模式可嘗試調用cancel進行任務取消。

系統(tǒng)能力： SystemCapability.Utils.Lang

參數：

返回值：

錯誤碼：

以下錯誤碼的詳細介紹請參見[語言基礎類庫錯誤碼]。

示例：

@Concurrent
function printArgs(args) {
    console.log("printArgs: " + args);
    return args;
}

async function taskpoolExecute() {
  let task = new taskpool.Task(printArgs, 100);
  let value = await taskpool.execute(task);
  console.log("taskpool result: " + value);
}

taskpoolExecute();

[](https://gitee.com/openharmony/docs/blob/OpenHarmony-3.2-Release/zh-cn/application-dev/reference/apis/js-apis-taskpool.md#taskpoolcancel)taskpool.cancel

cancel(task: Task): void

取消任務池中的任務。

系統(tǒng)能力： SystemCapability.Utils.Lang

參數：

錯誤碼：

以下錯誤碼的詳細介紹請參見[語言基礎類庫錯誤碼]。

任務取消成功示例：

@Concurrent
function printArgs(args) {
    console.log("printArgs: " + args);
    return args;
}

async function taskpoolCancel() {
  let task = new taskpool.Task(printArgs, 100);
  taskpool.execute(task);
  try {
    taskpool.cancel(task);
  } catch (e) {
    console.log("taskpool.cancel occur error:" + e);
  }
}

taskpoolCancel();

已執(zhí)行的任務取消失敗示例：

@Concurrent
function printArgs(args) {
    console.log("printArgs: " + args);
    return args;
}

async function taskpoolCancel() {
  let task = new taskpool.Task(printArgs, 100);
  let value = taskpool.execute(task);
  let start = new Date().getTime();
  while (new Date().getTime() - start < 1000) { // 延時1s，確保任務已執(zhí)行
    continue;
  }

  try {
    taskpool.cancel(task); //任務已執(zhí)行,取消失敗
  } catch (e) {
    console.log("taskpool.cancel occur error:" + e);
  }
}

taskpoolCancel();

正在執(zhí)行的任務取消失敗示例：

@Concurrent
function printArgs(args) {
    console.log("printArgs: " + args);
    return args;
}

async function taskpoolCancel() {
  let task1 = new taskpool.Task(printArgs, 100);
  let task2 = new taskpool.Task(printArgs, 200);
  let task3 = new taskpool.Task(printArgs, 300);
  let task4 = new taskpool.Task(printArgs, 400);
  let task5 = new taskpool.Task(printArgs, 500);
  let task6 = new taskpool.Task(printArgs, 600);

  let res1 = taskpool.execute(task1);
  let res2 = taskpool.execute(task2);
  let res3 = taskpool.execute(task3);
  let res4 = taskpool.execute(task4);
  let res5 = taskpool.execute(task5);
  let res6 = taskpool.execute(task6);
  try {
    taskpool.cancel(task1); // task1任務正在執(zhí)行，取消失敗
  } catch (e) {
    console.log("taskpool.cancel occur error:" + e);
  }
}

taskpoolCancel();

Priority

表示所創(chuàng)建任務（Task）的優(yōu)先級。（暫未支持）

系統(tǒng)能力： SystemCapability.Utils.Lang

Task

表示任務。使用以下方法前，需要先構造Task。

constructor

constructor(func: Function, ...args: unknown[])

Task的構造函數。

系統(tǒng)能力： SystemCapability.Utils.Lang

參數：

錯誤碼：

以下錯誤碼的詳細介紹請參見[語言基礎類庫錯誤碼]。

示例：

@Concurrent
function printArgs(args) {
    console.log("printArgs: " + args);
    return args;
}

let task = new taskpool.Task(printArgs, "this is my first Task");

屬性

系統(tǒng)能力： SystemCapability.Utils.Lang

其他說明

序列化支持類型

序列化支持類型包括：All Primitive Type(不包括symbol)、Date、String、RegExp、Array、Map、Set、Object、ArrayBuffer、TypedArray。

注意事項

• 僅支持在Stage模型且module的compileMode為esmodule的project中使用taskpool api。確認module的compileMode方法：查看當前module的build-profile.json5，在buildOption中補充"compileMode": "esmodule"。
• taskpool任務只支持引用入參傳遞或者import的變量，不支持使用閉包變量，使用裝飾器@Concurrent進行攔截。
• taskpool任務只支持普通函數或者async函數，不支持類成員函數或者匿名函數，使用裝飾器@Concurrent進行攔截。
• 裝飾器@Concurrent僅支持在ets文件使用。

簡單使用

示例一

// 支持普通函數、引用入參傳遞
@Concurrent
function printArgs(args) {
    console.log("printArgs: " + args);
    return args;
}

async function taskpoolExecute() {
  // taskpool.execute(task)
  let task = new taskpool.Task(printArgs, "create task, then execute");
  let val1 = await taskpool.execute(task);
  console.log("taskpool.execute(task) result: " + val1);

  // taskpool.execute(function)
  let val2 = await taskpool.execute(func, "execute task by func");
  console.log("taskpool.execute(function) result: " + val2);
}

taskpoolExecute();

示例二

// b.ets
export let c = 2000;

// 引用import變量
// a.ets(與b.ets位于同一目錄中)
import { c } from "./b";

@Concurrent
function printArgs(a) {
    console.log(a);
    console.log(c);
    return a;
}

async function taskpoolExecute() {
  // taskpool.execute(task)
  let task = new taskpool.Task(printArgs, "create task, then execute");
  let val1 = await taskpool.execute(task);
  console.log("taskpool.execute(task) result: " + val1);

  // taskpool.execute(function)
  let val2 = await taskpool.execute(printArgs, "execute task by func");
  console.log("taskpool.execute(function) result: " + val2);
}

taskpoolExecute();

示例三

// 支持async函數
@Concurrent
async function delayExcute() {
  let ret = await Promise.all([
    new Promise(resolve = > setTimeout(resolve, 1000, "resolved"))
  ]);
  return ret;
}

async function taskpoolExecute() {
  taskpool.execute(delayExcute).then((result) = > {
    console.log("TaskPoolTest task result: " + result);
  });
}

taskpoolExecute();

示例四

// c.ets
@Concurrent
function strSort(inPutArr) {
  let newArr = inPutArr.sort();
  return newArr;
}
export async function func1() {
    console.log("taskpoolTest start");
    let strArray = ['c test string', 'b test string', 'a test string'];
    let task = new taskpool.Task(strSort, strArray);
    let result = await taskpool.execute(task);
    console.log("func1 result:" + result);
}

export async function func2() {
    console.log("taskpoolTest2 start");
    let strArray = ['c test string', 'b test string', 'a test string'];
    taskpool.execute(strSort, strArray).then((result) = > {
        console.log("func2 result: " + result);
    });
}

// a.ets(與c.ets在同一目錄中)
import { taskpoolTest1, taskpoolTest2 } from "./c";

func1();
func2();

審核編輯 黃宇