HarmonyOS 鸿蒙Next中taskpool多线程问题

这个系统的报错原因是什么

08-01 19:43:15.688 4933-5193 C03F00/com.exa…y/ArkCompiler pid-4933 E [ecmascript] invalid size of the string cache table or the table has been registered.

08-01 19:43:15.688 4933-5193 C03F00/com.exa…y/ArkCompiler pid-4933 E [ecmascript] Currently, maximum size of the table is 150

另外我执行下面的taskpool，在testNum较小时能够执行完，但是在testNum较大时，比如1000时就只有几百个线程能执行，剩下的不执行，但是console.error也没有报错信息

let ids: number[] = [];
for (let i = 0; i < this.testNum; i++) {
  ids.push(i);
}

try{
let tasks = ids.map(id => {
  j=j+1;
  const t = new taskpool.Task(workerFunction, this.context, id);
  const p = taskpool.execute(t);
  return p;
});
let results: ProcessResult[] = [];
let i=0;
for (const p of tasks) {
  try{
    i=i+1;
    let r = await p;
  } catch (error) {
    console.error(`Task ${i} failed:`, error);
  }
}
} catch (error) {
  console.error(`Task  failed:`, error);
}

更多关于HarmonyOS 鸿蒙Next中taskpool多线程问题的实战教程也可以访问 https://www.itying.com/category-93-b0.html

yibo5220 1楼

08-01 19:43:15.688 4933-5193 pid-4933 E [ecmascript] Currently, maximum size of the table is 150

错误信息明确提到 “字符串缓存表大小无效或已注册，当前最大限制为 150”，这通常与多线程环境下的资源竞争或限制有关

控制并发数，避免一次性提交过多任务

采用 “分批执行” 策略，限制同时运行的任务数量（如每次执行 50 个），避免压垮任务池：

const BATCH_SIZE = 50; // 每批执行的任务数
const ids = [...]; // 你的任务ID列表
const results: ProcessResult[] = [];

// 分批处理任务
for (let i = 0; i < ids.length; i += BATCH_SIZE) {
  const batchIds = ids.slice(i, i + BATCH_SIZE);
  // 创建当前批次的任务
  const batchTasks = batchIds.map((id, idx) => {
    const task = new taskpool.Task(workerFunction, this.context, id);
    return {
      promise: taskpool.execute(task),
      index: i + idx // 记录原始索引，方便定位错误
    };
  });
  
  // 等待当前批次所有任务完成
  for (const { promise, index } of batchTasks) {
    try {
      const result = await promise;
      results.push(result);
      console.log(`Task ${index} completed`);
    } catch (error) {
      console.error(`Task ${index} failed:`, error);
    }
  }
}

更多关于HarmonyOS 鸿蒙Next中taskpool多线程问题的实战系列教程也可以访问 https://www.itying.com/category-93-b0.html

caililin 2楼

鸿蒙Next的taskpool是基于ArkTS并发模型的多线程解决方案，提供Task和TaskGroup两类API。TaskPool通过工作窃取算法实现任务自动分配，线程池默认大小为CPU核心数-1。使用示例：

import taskpool from '@ohos.taskpool';
[@Concurrent](/user/Concurrent)
function computeTask(data: number): number {
  // 耗时操作
  return data * 2;
}

let task = new taskpool.Task(computeTask, 100);
taskpool.execute(task).then((res) => {
  console.log(res); // 输出200
});

TaskPool任务需标注@Concurrent装饰器，函数参数和返回值需支持序列化。

zlyuanteng 3楼

关于HarmonyOS Next中taskpool多线程问题的分析：

字符串缓存表错误分析：

报错显示字符串缓存表大小无效或已注册，最大限制为150
这可能是由于ArkCompiler在管理字符串资源时达到了预设上限
建议检查代码中是否存在大量字符串操作或重复创建字符串对象的情况

taskpool执行问题分析：

当testNum较大时(如1000)，部分任务未执行但无报错
这可能是由于系统线程池资源耗尽导致的静默失败
HarmonyOS的taskpool有默认的并发限制，大量任务会排队等待

改进建议：

对于字符串缓存问题：
- 优化字符串处理逻辑，避免频繁创建
- 考虑复用字符串对象
对于taskpool问题：
- 分批处理任务，控制并发量
- 使用任务组(taskgroup)管理大量任务
- 添加任务状态监控逻辑

性能优化方向：

合理设置任务粒度，避免过于细小的任务
考虑使用任务优先级机制
监控系统资源使用情况