当前位置：首页 > news >正文

【HarmonyOS NEXT】多线程并发-taskpool

news 2026/3/26 19:51:23

一、背景

在鸿蒙开发中提供了两种多线程并发方案，分别是TaskPool与Worker，此篇文章主要总结下TaskPool

二、TaskPool概念

1、TaskPool是为应用提供多线程运行环境，旨在降低资源消耗并提升系统性能

2、开发者无需关心线程的生命周期，由系统统一管理线程的创建、调度和销毁

三、怎么用

使用TaskPool流程：定义任务 → 提交任务 → 处理结果 → 取消任务（可选）

步骤一：定义耗时任务（必须用 @Concurrent 标记）

所有提交到 TaskPool 的耗时函数，必须通过@Concurrent装饰器标记——这是鸿蒙的强制要求，用于告知系统“该函数是耗时任务，需在后台线程执行”。

注意：该函数需满足「无状态、参数可序列化」，不能直接操作 UI（如修改 @State 变量、调用 UI 组件方法）。

@Concurrent function computeTask(a: number, b: number): number { let start = Date.now(); while (Date.now() - start < 2000) { } // 阻塞2秒（后台线程，不影响UI） return a + b; }

步骤二、提交任务+处理结果

创建 Task 实例，将函数和参数包装起来；提交到任务池执行，并等待 Promise 返回的结果

export class taskpoolUtils { private static instance: taskpoolUtils | undefined; public static getInstance(): taskpoolUtils { if (!taskpoolUtils.instance) { taskpoolUtils.instance = new taskpoolUtils(); } return taskpoolUtils.instance; } async runConcurrentTask() { try { // 1. 同步创建Task实例 const task: taskpool.Task = new taskpool.Task(computeTask, 10, 20); // 2. 提交任务到后台线程 const result = await taskpool.execute(task); console.log('lucy== 计算结果result', result); // 2秒后打印30 } catch (err) { // 捕获任务执行异常 console.error('lucy== 任务执行失败', JSON.stringify(err)); } } }

最终效果执行

import { ScreenUtils } from '../utils/ScreenUtils'; import { taskpoolUtils } from '../utils/taskpoolUtils' @Entry @Component struct Index { private globalNavStack: NavPathStack = new NavPathStack(); //UI状态，验证taskpool不阻塞UI @State uiText: string = '未执行任务'; build() { Column() { Navigation(this.globalNavStack) { // 显示UI状态，验证是否阻塞 Text(this.uiText).fontSize(20).margin(20); Button('跳转到login组件+执行耗时任务') .onClick(() => { // 1. 先更新UI（验证UI线程没被阻塞） this.uiText = '任务执行中...'; // 2. 跳转页面（UI操作） this.globalNavStack.pushPathByName('loginPage', null, false); // 3. 执行taskpool耗时任务 taskpoolUtils.getInstance().runConcurrentTask().then(() => { // 任务完成后更新UI this.uiText = '任务执行完成'; }); // 4. 验证：任务执行中，UI仍能响应（立即打印，不会等2秒） console.log('lucy== UI线程未阻塞，立即执行'); }) } .height('100%') .width('100%') .padding({ top: ScreenUtils.getInstance().getStatusBarHeight() }) } } }

四、适用场景