输入关键字搜索
开发者能力认证
鸿蒙高校创新赛
HarmonyOS 7
animation
HarmonyOS行业解决方案
layoutWeight
HarmonyOS模板&组件
bindPopup
bindsheet
CTRL+K
文档管理中心

HarmonyOS

输入关键字搜索
开发者能力认证
鸿蒙高校创新赛
HarmonyOS 7
animation
HarmonyOS行业解决方案
layoutWeight
HarmonyOS模板&组件
bindPopup
bindsheet
CTRL+K
指南
指南应用框架ArkTS（方舟编程语言）ArkTS并发应用多线程开发实践应用多线程开发实践案例TaskPool指定任务并发度场景

TaskPool指定任务并发度场景

更新时间: 2026-08-18 12:49

TaskPool支持使用异步队列来控制任务的并发度，能有效避免资源过载，减少任务阻塞，适用于网络请求、视频流处理和数据库操作等场景。

此处提供使用TaskPool创建异步队列的开发指导，以相机预览流采集数据处理的功能为例。

由于处理过程是一个频繁且耗时的任务，当相机采集速度过快时，将丢弃之前的采集数据，仅保留最新的一帧数据进行处理。

  1. 导入需要用到的模块。

    // TaskpoolAsyncLevel.ets
import { taskpool } from '@kit.ArkTS';
import { BusinessError } from '@kit.BasicServicesKit';
import { PromptAction } from '@kit.ArkUI';
    TaskpoolAsyncLevel.ets

  2. 定义耗时任务。

    // TaskpoolAsyncLevel.ets
@Concurrent
function collectFrame() {
  // 采集数据，并且进行处理
  // 模拟处理过程，这里是个耗时任务，持续时间为30秒
  let t = new Date().getTime()
  while (new Date().getTime() - t < 30000) {
    continue;
  }
  console.info('collectFrame finished');
}
    TaskpoolAsyncLevel.ets

  3. 创建异步队列并执行采集任务。

    // TaskpoolAsyncLevel.ets
@Entry
@Component
struct TaskpoolAsyncLevel {
  @State message: string = '触发采集任务';
  @State returnMessage: string = 'return...';
  @State promptAction: PromptAction = this.getUIContext().getPromptAction();
  
  build() {
    Row() {
      Column() {
        Button(this.message)
          .fontSize(50)
          .fontWeight(FontWeight.Bold)
          .onClick(async () => {
            // 创建并发度为5的异步队列，等待队列个数为5，当加入的任务数量超过5时，等待列表中处于队头的任务会被丢弃
            let asyncRunner: taskpool.AsyncRunner = new taskpool.AsyncRunner('async', 5, 5);
            // 触发采集任务
            let promises: Promise<void>[] = [];
            for (let i = 0; i < 20; i++) {
              let task: taskpool.Task = new taskpool.Task(`async${i}`, collectFrame);
              let p: Promise<void> = asyncRunner.execute(task).then(() => {
                console.info('the current task name is ' + task.name);
              }).catch((e: BusinessError) => {
                console.error('async: error is ' + e);
              });
              promises.push(p);
            }
            // 等待所有任务完成后再执行后续语句
            await Promise.allSettled(promises);
            console.info('asyncRunner tasks submitted');
            this.returnMessage = 'asyncRunner task finished';
            this.promptAction.showToast({ message: this.returnMessage });
          })
        // ...
      }
      .width('100%')
    }
    .height('100%')
  }
}
    TaskpoolAsyncLevel.ets
C++线程间数据共享场景
ArkUI瀑布流渲染场景
相关推荐
文档I/O密集型任务开发指导 (TaskPool)
文档TaskPool简介
文档长时任务并发场景简介
文档TaskPool使用规范
文档长时任务开发指导 (TaskPool)
文档同步任务开发指导 (TaskPool和Worker)
文档@ohos.taskpool (启动任务池)
文档并发能力使用
文档使用TaskPool执行多个耗时任务
示例代码基于TaskPool实现多线程任务
简体中文
华为开发者联盟 版权所有 ©2026
问题反馈
使用条款
华为开发者联盟用户协议
关于华为开发者联盟与隐私的声明
Cookies
开源软件声明
在 指南 中进行搜索
请输入您想要搜索的关键词