TaskPool指定任务并发度场景

此处提供使用TaskPool创建异步队列的开发指导，以相机预览流采集数据处理的功能为例。由于处理过程是个频繁耗时任务，如果相机采集过快，就丢弃之前的采集数据，缓存最新的一帧数据处理。

导入需要用到的模块。

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

定义长时任务。

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

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

// Index.ets
@Entry
@Component
struct Index {
  sensorTask?: taskpool.LongTask

  build() {
    Column() {
      Text("HELLO WORLD")
        .id('HelloWorld')
        .fontSize(50)
        .fontWeight(FontWeight.Bold)
        .onClick(() => {
          // 创建并发度为5的异步队列，等待队列个数为5。
          let asyncRunner:taskpool.AsyncRunner = new taskpool.AsyncRunner("async", 5, 5);
          // 每秒触发一次采集任务
          setTimeout(() => {
            let task:taskpool.Task = new taskpool.Task(collectFrame);
             asyncRunner.execute(task);
           }, 1000);
        })
    }
    .height('100%')
    .width('100%')
  }
}