收起
自动换行
深色代码主题
复制
import { ArkTSUtils, taskpool } from '@kit.ArkTS';

@Concurrent
function notifyAll(conditionVariable: ArkTSUtils.locks.ConditionVariable) {
  console.info(`TaskPool Thread notifyAll`);
  conditionVariable.notifyAll();
}

@Concurrent
function notifyOne(conditionVariable: ArkTSUtils.locks.ConditionVariable) {
  console.info(`TaskPool Thread notifyOne`);
  conditionVariable.notifyOne();
}

@Concurrent
async function wait(conditionVariable: ArkTSUtils.locks.ConditionVariable) {
  await conditionVariable.wait();
  console.info(`TaskPool Thread Wait: success`);
}

@Concurrent
async function waitFor(conditionVariable: ArkTSUtils.locks.ConditionVariable) {
  await conditionVariable.waitFor(3000);
  console.info(`TaskPool Thread WaitFor: success`);
}

@Entry
@Component
struct Index {
  @State message: string | ResourceStr = $r('app.string.AsyncButton'); // 加载资源，可根据项目实际资源自定义

  build() {
    Row() {
      Column() {
        Button(this.message)
          .fontSize(25)
          .fontWeight(FontWeight.Bold)
          .onClick(async () => {
            // 创建conditionVariable对象。
            const conditionVariable: ArkTSUtils.locks.ConditionVariable = new ArkTSUtils.locks.ConditionVariable();
            // 将实例conditionVariable传递给wait线程。
            taskpool.execute(wait, conditionVariable);
            // 将实例conditionVariable传递给notifyAll线程，唤醒wait线程，日志输出"TaskPool Thread Wait: success"。
            await taskpool.execute(notifyAll, conditionVariable);
            // 将实例conditionVariable传递给waitFor线程。
            taskpool.execute(waitFor, conditionVariable);
            // 将实例conditionVariable传递给notifyOne线程，唤醒waitFor线程，日志输出"TaskPool Thread WaitFor: success"。
            await taskpool.execute(notifyOne, conditionVariable);

            // 创建有name的conditionVariable对象。
            const conditionVariableRequest: ArkTSUtils.locks.ConditionVariable =
              ArkTSUtils.locks.ConditionVariable.request('Request1');
            // 将实例conditionVariableRequest传递给wait线程。
            taskpool.execute(wait, conditionVariableRequest);
            // 将实例conditionVariableRequest传递给notifyAll线程，唤醒wait线程，日志输出"TaskPool Thread Wait: success"。
            await taskpool.execute(notifyAll, conditionVariableRequest);
            // 将实例conditionVariableRequest传递给waitFor线程。
            taskpool.execute(waitFor, conditionVariableRequest);
            // 将实例conditionVariableRequest传递给notifyOne线程，唤醒waitFor线程，日志输出"TaskPool Thread WaitFor: success"。
            await taskpool.execute(notifyOne, conditionVariableRequest);
          })
      }
      .width('100%')
    }
    .height('100%')
  }
}
Index.ets

异步锁

ASON解析与生成

意见反馈

以上内容对您是否有帮助？

意见反馈

如果您有其他疑问，您也可以通过开发者社区问答频道来和我们联系探讨。

社区提问智能客服提问