ArkTS 异步并发

📅 2026/7/24 9:19:21 👁️ 阅读次数 📝 编程学习
ArkTS 异步并发

Promise 和 async/await 是标准的 JS 异步语法,提供异步并发能力。异步代码执行时会被挂起,在异步操作完成后恢复执行,确保同一时间只有一段代码在运行。以下是典型的异步并发使用场景:

  • I/O 非阻塞操作:网络请求、文件读写、定时器等。
  • 任务轻量且无 CPU 阻塞:单次任务执行时间短。
  • 逻辑依赖清晰:任务有明确的顺序或并行关系。

异步并发是一种编程语言的特性,允许程序在执行某些操作时不必等待其完成,可以继续执行其他异步代码。

Promise

Promise 是一种用于处理异步操作的对象,可将异步操作转换为类似同步操作的风格,便于代码编写和维护。Promise 通过状态机制管理异步操作的不同阶段,有三种状态:pending(进行中)、fulfilled(已完成,也叫 resolved)和rejected(已拒绝)。创建后处于 pending 状态,异步操作完成后转换为 fulfilled 或 rejected 状态。

Promise 提供了 then、catch、finally 方法来注册回调函数,以处理异步操作的成功或失败结果。当 Promise 状态改变时,回调函数会被加入微任务队列等待执行,依赖事件循环机制在宏任务执行完成后优先执行微任务,从而保证回调函数的异步调度。

最基本的用法是通过构造函数实例化一个 Promise 对象,传入一个带有两个参数的函数,称为 executor 函数。executor 函数接收两个参数:resolve 和 reject,分别表示异步操作成功和失败时的回调函数。

例如,以下代码创建了一个 Promise 对象并模拟了一个异步操作:

const promise: Promise<number> = new Promise((resolve: Function, reject: Function) => { setTimeout(() => { const randomNumber: number = Math.random(); if (randomNumber > 0.5) { resolve(randomNumber); } else { reject(new Error('Random number is too small')); } }, 1000); })

在上述代码中,setTimeout 函数模拟了一个异步操作,1 秒后生成一个随机数。如果随机数大于 0.5,调用 resolve 回调函数并传递该随机数;否则调用 reject 回调函数并传递一个错误对象。

Promise 对象创建后,可以使用 then 方法和 catch 方法指定 fulfilled 状态和 rejected 状态的回调函数。then 方法可接受两个参数,一个处理 fulfilled 状态的函数,另一个处理 rejected 状态的函数。只传一个参数则表示当 Promise 对象状态变为 fulfilled 时,then 方法会自动调用这个回调函数,并将 Promise 对象的结果作为参数传递给它。使用 catch 方法注册一个回调函数,用于处理“失败”的结果,即捕获 Promise 的状态改变为 rejected 状态或操作失败抛出的异常。Promise 还可以使用 finally 注册回调函数,无论 Promise 最终状态如何(fulfilled 或 rejected),都会执行该回调函数。例如:

import { BusinessError } from '@kit.BasicServicesKit'; // ... /* * Promise 对象创建后,可以使用 then 方法和 catch 方法指定 fulfilled 状态和 rejected 状态的回调函数。 * then 方法可接受两个参数,一个处理 fulfilled 状态的函数,另一个处理 rejected 状态的函数。 * * 只传一个参数则表示当 Promise 对象状态变为 fulfilled 时,then 方法会自动调用这个回调函数,并将 Promise 对象的结果作为参数传递给它。 * 使用 catch 方法注册一个回调函数,用于处理“失败”的结果,即捕获 Promise 的状态改变为 rejected 状态或操作失败抛出的异常。 */ // 使用 then 方法定义成功和失败的回调 promise.then((result: number) => { console.info(`Succeeded in getting number, number is ${result}`); // 成功时执行 }, (error: BusinessError) => { console.error(error.message); // 失败时执行 } ); // 使用 then 方法定义成功的回调,catch 方法定义失败的回调 promise.then((result: number) => { console.info(`Succeeded in getting number, number is ${result}`); // 成功时执行 }).catch((error: BusinessError) => { console.error(error.message); // 失败时执行 });

在上述代码中,then 方法的回调函数接收 Promise 对象的成功结果,并输出至控制台。如果 Promise 对象进入 rejected 状态,catch 方法的回调函数接收错误对象,并输出至控制台。

当 Promise 被 reject 且未通过 catch 方法处理时,会触发 globalUnhandledRejectionDetected 事件。可使用 errorManager.on(‘globalUnhandledRejectionDetected’) 接口监听该事件,以全局捕获未处理的 Promise reject。

async/await

async/await 是用于处理异步操作的 Promise 语法糖,使编写异步代码更加简单和易读。使用 async 关键字声明异步函数,并使用 await 关键字等待 Promise 的解析(fulfilled 或 rejected),以同步方式编写异步操作的代码。

async 函数返回 Promise 对象,实现异步操作。函数内部可包含零个或多个 await 关键字,await 会暂停执行,直到关联的 Promise 完成状态转换(fulfilled 或 rejected)。若函数执行过程中抛出异常,该异常将直接触发返回的 Promise 进入 rejected 状态,错误对象可通过 catch 方法或 then 的第二个回调参数捕获。

下面是一个使用 async/await 的示例,模拟同步方法执行异步操作的场景,3 秒后返回一个字符串。

async function myAsyncFunction(): Promise<string> { const result: string = await new Promise((resolve: Function) => { setTimeout(() => { resolve('Hello, world!'); }, 3000); }); console.info(result); // 输出: Hello, world! return result; } @Entry @Component struct PromiseAsyncAwait { @State message: string = 'Hello World'; build() { Row() { Column() { Text(this.message) .fontSize(50) .fontWeight(FontWeight.Bold) .onClick(async () => { let res = await myAsyncFunction(); console.info('Result is: ' + res); this.message = 'success'; }) } .width('100%') } .height('100%') } }