鸿蒙 harmonyos 线程 并发 总结 async promise Taskpool woker（二）多线程并发 Taskpool

多线程并发

并发模型是用来实现不同应用场景中并发任务的编程模型，常见的并发模型分为基于内存共享的并发模型和基于消息通信的并发模型。

ArkTS提供了TaskPool和Worker两种并发能力供开发者选择，其具体的实现特点和各自的适用场景存在差异。TaskPool（任务池）和Worker的作用是为应用程序提供一个多线程的运行环境，用于处理耗时的计算任务或其他密集型任务。可以有效地避免这些任务阻塞主线程，从而最大化系统的利用率，降低整体资源消耗，并提高系统的整体性能。

TaskPool和Worker的对比

表1 TaskPool和Worker的实现特点对比

适用场景对比

TaskPool和Worker均支持多线程并发能力。TaskPool偏向独立任务维度，该任务在线程中执行，无需关注线程的生命周期；而Worker偏向线程的维度，支持长时间占据线程执行，需要主动管理线程生命周期。

常见的一些开发场景及适用具体说明如下：

• 有关联的一系列同步任务。例如在一些需要创建、使用句柄的场景中，句柄创建每次都是不同的，该句柄需永久保存，保证使用该句柄进行操作，需要使用Worker。
• 需要频繁取消的任务。例如图库大图浏览场景，为提升体验，会同时缓存当前图片左右侧各2张图片，往一侧滑动跳到下一张图片时，要取消另一侧的一个缓存任务，需要使用TaskPool。
• 大量或者调度点较分散的任务。例如大型应用的多个模块包含多个耗时任务，不方便使用8个Worker去做负载管理，推荐采用TaskPool。

taskpool

taskpool，通过管理Task进行多线程的，通过taskpool.execute执行的，返回Promise对象。

Task的构造方法Task(func,args),func是执行的函数，该函数func需要用@Concurrent装饰器进行装饰，否则不会通过验证。

taskpool是可以通过taskpool.cancel结束Task任务的，也算是一种管理吧。

@Concurrent仅支持在Stage模型中使用，args是func的参数。@Concurrent装饰器不能在控件中声明。

taskpool.Task是有优先级的，执行的时候通过taskpool.Priority.HIGH标记优先级的

@Concurrent
function func(args) {
  console.log("func: " + args);
  return args;
}
 
const task: taskpool.Task = new taskpool.Task(func,"kang");
taskpool.execute(task, taskpool.Priority.HIGH);
taskpool.cancel(task);

执行Task后想获得其结果，可以用async/awaite获取

@Concurrent
function func(args) {
    console.log("func: " + args);
    return args;
}
 
async function taskpoolTest() {
  let task = new taskpool.Task(func, 100);
  let value = await taskpool.execute(task);
  console.log("taskpool result: " + value);
}
 
taskpoolTest();

taskpool实际应用

CPU密集型任务是指需要占用系统资源处理大量计算能力的任务，需要长时间运行，这段时间会阻塞线程其它事件的处理，不适宜放在主线程进行。例如图像处理、视频编码、数据分析等。

基于多线程并发机制处理CPU密集型任务可以提高CPU利用率，提升应用程序响应速度。

示例：

import taskpool from '@ohos.taskpool';
 
@Concurrent
function imageProcessing(dataSlice: ArrayBuffer) {
  // 步骤1: 具体的图像处理操作及其他耗时操作
  return dataSlice;
}
 
function histogramStatistic(pixelBuffer: ArrayBuffer) {
  // 步骤2: 分成三段并发调度
  let number = pixelBuffer.byteLength / 3;
  let buffer1 = pixelBuffer.slice(0, number);
  let buffer2 = pixelBuffer.slice(number, number * 2);
  let buffer3 = pixelBuffer.slice(number * 2);
 
  let task1 = new taskpool.Task(imageProcessing, buffer1);
  let task2 = new taskpool.Task(imageProcessing, buffer2);
  let task3 = new taskpool.Task(imageProcessing, buffer3);
 
  taskpool.execute(task1).then((ret: ArrayBuffer[]) => {
    // 步骤3: 结果处理
  });
  taskpool.execute(task2).then((ret: ArrayBuffer[]) => {
    // 步骤3: 结果处理
  });
  taskpool.execute(task3).then((ret: ArrayBuffer[]) => {
    // 步骤3: 结果处理
  });
}
 
@Entry
@Component
struct Index {
  @State message: string = 'Hello World'
 
  build() {
    Row() {
      Column() {
        Text(this.message)
          .fontSize(50)
          .fontWeight(FontWeight.Bold)
          .onClick(() => {
            let data: ArrayBuffer;
            histogramStatistic(data);
          })
      }
      .width('100%')
    }
    .height('100%')
  }
}

今天关于并发的就先写到这，下一篇woker

本人创业失败，要找工作，想找一个鸿蒙开发的工作，要我的请私信我。