HarmonyOS 鸿蒙Next Taskpool实现多线程demo

HarmonyOS 鸿蒙Next Taskpool实现多线程demo

1、Taskpool是什么？

Taskpool的作用是为应用程序提供一个多线程的运行环境，降低整体资源的消耗、提高系统的整体性能，且不用使用者关心线程实例的生命周期。简而言之就是需要的时候，拿来就用即可，用完就走，也不用关系线程资源的回收等逻辑。并且系统在实现Taskpool的时候，也做了一定的性能优化，整体上要比我们自己管理线程更高效一些。

TaskPool支持开发者在主线程封装任务抛给任务队列，系统选择合适的工作线程，进行任务的分发及执行，再将结果返回给主线程。接口直观易用，支持任务的执行、取消，以及指定优先级的能力，同时通过系统统一线程管理，结合动态调度及负载均衡算法，可以节约系统资源。系统默认会启动一个任务工作线程，当任务较多时会扩容，工作线程数量上限跟当前设备的物理核数相关，具体数量内部管理，保证最优的调度及执行效率，长时间没有任务分发时会缩容，减少工作线程数量。

2、Taskpool的应用场景

长时任务（网络下载、文件读写等I/O任务等promise异步任务）和执行时长不超过3分钟的任务，比如训练任务时长都比较长，就不适合使用Taskpool

3、Taskpool的工作原理

Taskpool运作示意图

4、Taskpool使用案例

import { taskpool } from '@kit.ArkTS';

@Concurrent
function calcDe(val: number = 18) : number {
  console.info('BB: calc：', val)
  let re = 1
  for(let i=1; i < val + 1; i++) {
    re *= i;
  }
  console.info('info: ', re)
  return re;
}

function taskpoolExecTool(param: number, callback: (re: Object) => void) {
  taskpool.execute(new taskpool.Task(calcDe, param), taskpool.Priority.HIGH).then((result: Object) => {
    console.info("taskPoolTest task result: " + result);
    callback(result);
  }).catch((err: string) => {
    console.error("taskPoolTest test occur error: " + err);
  })
}


@Entry
@Component
struct Index {
  @State param: string = ''
  @State result: number | undefined = undefined;

  build() {
    Column() {
      Row(){
        Text('请输入一个数字: ')
        TextInput().onChange((val) => {
          this.param = val
        })
      }.height(60)
      Button('Calc').onClick(async () => {
        taskpoolExecTool(Number(this.param), (re: Object) => {
          this.result = Number(re);
        })
      }).height(60)
      Text(this.result?.toString()).height(60)
    }
    .height('100%')
    .width('100%')
    .justifyContent(FlexAlign.Center)
  }
}