# TaskPool指定任务并发度场景
<!--Kit: ArkTS-->
<!--Subsystem: CommonLibrary-->
<!--Owner: @lijiamin2025-->
<!--Designer: @weng-changcheng-->
<!--Tester: @kirl75; @zsw_zhushiwei-->
<!--Adviser: @ge-yafang-->

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

此处提供使用TaskPool创建[异步队列](../reference/apis-arkts/js-apis-taskpool.md#asyncrunner18)的开发指导，以相机预览流采集数据处理的功能为例。
由于处理过程是一个频繁且耗时的任务，当相机采集速度过快时，将丢弃之前的采集数据，仅保留最新的一帧数据进行处理。

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

   ```ts
   // Index.ets
   import { taskpool } from '@kit.ArkTS';
   import { BusinessError } from '@kit.BasicServicesKit';
   ```

2. 定义耗时任务。

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

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

   ```ts
   // Index.ets
   @Entry
   @Component
   struct Index {
     @State message: string = 'Hello World';
   
     build() {
       Row() {
         Column() {
           Text(this.message)
             .fontSize(50)
             .fontWeight(FontWeight.Bold)
             .onClick(async () => {
               // 创建并发度为5的异步队列，等待队列个数为5，当加入的任务数量超过5时，等待列表中处于队头的任务会被丢弃。
               let asyncRunner:taskpool.AsyncRunner = new taskpool.AsyncRunner("async", 5, 5);
               // 触发采集任务
               for (let i = 0; i < 20; i++) {
                 let task:taskpool.Task = new taskpool.Task(`async${i}`,collectFrame);
                 asyncRunner.execute(task).then(() => {
                   console.info("the current task name is " + task.name);
                 }).catch((e:BusinessError) => {
                   console.error("async: error is " + e);
                 });
               }
               console.info("asyncRunner task finished");
             })
         }
         .width('100%')
       }
       .height('100%')
     }
   }
   ```