HarmonyOS鸿蒙Next开发过程中有没有遇到锁的问题？

楼主，例如在taskPool中搭配异步锁实现多线程中任意一次请求接口成功后，其余线程不再请求接口。

以下是问题的描述以及解决方案：

【问题现象】

ArkTS并发编程时，会多次请求同一接口，目前希望能使用taskPool搭配异步锁实现并发请求时接口成功被调用一次后可以不重复调用接口：例如多个线程任务同时执行A方法，执行完A方法后都请求B接口。期望只要有一个线程任务请求B接口成功后其他的线程执行完A就结束，不再继续请求B接口。

【背景知识】

• taskPool为应用程序提供多线程环境，降低资源消耗、提高系统性能，无需管理线程生命周期。
• AsyncLock是一种专为异步编程设计的同步机制，主要用于解决异步环境下的资源竞争和并发控制问题。为了解决多线程并发任务间的数据竞争问题，ArkTS引入了异步锁能力。异步锁可能会被类对象持有，因此为了更方便地在并发实例间获取同一个异步锁对象，AsyncLock对象支持跨线程引用传递。

【解决方案】

1. 实现了一个HarmonyOS ArkTS环境下的全局状态管理类，声明异步锁并编写异步操作：

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

"use shared" // 指令声明模块为进程内共享单例

@Sendable
// 通过@Sendable装饰器确保类实例可跨线程安全传输
class GlobalState {
  private status: number = 1 // 1-状态正常  0-状态不正常
  public readonly MAX_RETRY_TIME: number = 3
  public retryTime: number = 0

  constructor() {

  }

  setState(status: number) {
    this.status = status
  }

  isConnected() {
    return this.status === 1
  }

  // 采用AsyncLock实现异步操作的互斥访问
  lock_: ArkTSUtils.locks.AsyncLock = new ArkTSUtils.locks.AsyncLock();

  public setLock(): string {
    // 对需要保护的数据加异步锁，使用异步锁保护临界区
    console.info('当前state1:' + this.status)
    if (!this.status) {
      console.info('处理中')
      this.setState(2);
      let start: number = new Date().getTime();
      while (new Date().getTime() - start < 1000) {
        continue;
      }
      console.info("处理成功")
      return 'success'
    }
    return 'success';
  }
}

export const globalState = new GlobalState()

1. 编写业务处理工具类，主模拟业务处理接口请求失败后的重试机制：

import { globalState } from './GlobalState';

class BusinessHandleUtil {
  static handleFlag: boolean = false;
  static handleCount: number = 0

  async handleBusiness(a: number, b: number): Promise<number> {

    return new Promise(async (resolve, reject) => {
      console.info(`开始处理业务`);

      let businessCode = this.handle()
      let result = a + b;
      if (businessCode === '10200000') {
        console.info(`业务处理失败1`);
        globalState.setState(0)
        globalState.lock_.lockAsync(() => {
          let start: number = new Date().getTime();
          while (new Date().getTime() - start < 2000) {
            continue;
          }
          if (businessCode === '10200000') {
            console.info(`业务处理失败2`);
            if (!globalState.isConnected()) {

              let flag = globalState.setLock() // 模拟业务处理
              if (flag === 'success') {
                globalState.retryTime = 0;
                globalState.setState(1);
                resolve(result);
              }
            }
            resolve(result);
          }
        })
      } else {
        console.info(`网络请求成功`);
        resolve(result);
      }
    });
  }

  // 模拟业务处理接口返回信息，一般情况返回成功
  handle(): string {
    globalState.retryTime++;
    let a = 1000;
    while (a < 10) {
      a--;
    }
    return '10200000'
  }
}

const httpTools = new BusinessHandleUtil();

export { httpTools }

1. 实现ArkTS的并发任务处理界面：

import { httpTools } from './BusinessHandleUtil';
import { taskpool } from '@kit.ArkTS';

// 使用@Concurrent装饰器标记可并行函数
@Concurrent
async function request(num1: number, num2: number): Promise<number> {
  return await httpTools.handleBusiness(num1, num2);
}

@Entry
@Component
struct Index {
  @State message: string = '点击开始执行业务';

  build() {
    Column() {
      Button(this.message)
        .onClick(async () => {
          // 点击文本触发10个并发任务
          for (let i = 0; i < 10; i++) {
            taskpool.execute(request, i + 1, i + 2) // 通过taskpool实现多任务并发执行
              .then(data => {
                console.info("data" + i + ":" + data);
              })
          }
        })

    }
    .width("100%")
    .height("100%")
    .justifyContent(FlexAlign.Center)
  }
}