文化公司网站建设策划书,wordpress显示文章列表,在线自助网站按照程序,专业seo培训学校一、并发概述
并发是指在同一时间段内#xff0c;能够处理多个任务的能力。为了提升应用的响应速度与帧率#xff0c;以及防止耗时任务对主线程的干扰#xff0c;HarmonyOS 系统提供了异步并发和多线程并发两种处理策略。
● 异步并发是指异步代码在执行到一定程度后会被暂…一、并发概述
并发是指在同一时间段内能够处理多个任务的能力。为了提升应用的响应速度与帧率以及防止耗时任务对主线程的干扰HarmonyOS 系统提供了异步并发和多线程并发两种处理策略。
● 异步并发是指异步代码在执行到一定程度后会被暂停以便在未来某个时间点继续执行这种情况下同一时间只有一段代码在执行。
● 多线程并发允许在同一时间段内同时执行多段代码。在主线程继续响应用户操作和更新 UI 的同时后台也能执行耗时操作从而避免应用出现卡顿。
并发能力在多种场景中都有应用其中包括单次 I/O 任务、CPU 密集型任务、I/O 密集型任务和同步任务等。开发者可以根据不同的场景选择相应的并发策略进行优化和开发。
ArkTS 支持异步并发和多线程并发。
● Promise 和 async/await 提供异步并发能力适用于单次 I/O 任务的开发场景。详细请参见异步并发概述。
● TaskPool 和 Worker 提供多线程并发能力适用于 CPU 密集型任务、I/O 密集型任务和同步任务等并发场景。详细请参见多线程并发概述。
二、 使用异步并发能力进行开发
1、 异步并发概述
Promise 和 async/await 提供异步并发能力是标准的 JS 异步语法。异步代码会被挂起并在之后继续执行同一时间只有一段代码执行适用于单次 I/O 任务的场景开发例如一次网络请求、一次文件读写等操作。
异步语法是一种编程语言的特性允许程序在执行某些操作时不必等待其完成而是可以继续执行其他操作。
1.1 Promise
Promise 是一种用于处理异步操作的对象可以将异步操作转换为类似于同步操作的风格以方便代码编写和维护。Promise 提供了一个状态机制来管理异步操作的不同阶段并提供了一些方法来注册回调函数以处理异步操作的成功或失败的结果。
Promise 有三种状态pending进行中、fulfilled已完成和 rejected已拒绝。Promise 对象创建后处于 pending 状态并在异步操作完成后转换为 fulfilled 或 rejected 状态。
最基本的用法是通过构造函数实例化一个 Promise 对象同时传入一个带有两个参数的函数通常称为 executor 函数。executor 函数接收两个参数resolve 和 reject分别表示异步操作成功和失败时的回调函数。例如以下代码创建了一个 Promise 对象并模拟了一个异步操作 const promise new Promise((resolve, reject) { setTimeout(() { const randomNumber 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 状态的函数。只传一个参数则表示状态改变就执行不区分状态结果。使用 catch 方法注册一个回调函数用于处理“失败”的结果即捕获 Promise 的状态改变为 rejected 状态或操作失败抛出的异常。例如 promise.then(result { console.info(Random number is ${result});}).catch(error { console.error(error.message);});
上述代码中then 方法的回调函数接收 Promise 对象的成功结果作为参数并将其输出到控制台上。如果 Promise 对象进入 rejected 状态则 catch 方法的回调函数接收错误对象作为参数并将其输出到控制台上。
1.2 async/await
async/await 是一种用于处理异步操作的 Promise 语法糖使得编写异步代码变得更加简单和易读。通过使用 async 关键字声明一个函数为异步函数并使用 await 关键字等待 Promise 的解析完成或拒绝以同步的方式编写异步操作的代码。
async 函数是一个返回 Promise 对象的函数用于表示一个异步操作。在 async 函数内部可以使用 await 关键字等待一个 Promise 对象的解析并返回其解析值。如果一个 async 函数抛出异常那么该函数返回的 Promise 对象将被拒绝并且异常信息会被传递给 Promise 对象的 onRejected()方法。
下面是一个使用 async/await 的例子其中模拟了一个异步操作该操作会在 3 秒钟后返回一个字符串。 async function myAsyncFunction() { const result await new Promise((resolve) { setTimeout(() { resolve(Hello, world!); }, 3000); }); console.info(String(result)); // 输出 Hello, world!}
myAsyncFunction();
在上述示例代码中使用了 await 关键字来等待 Promise 对象的解析并将其解析值存储在 result 变量中。
需要注意的是由于要等待异步操作完成因此需要将整个操作包在 async 函数中。除了在 async 函数中使用 await 外还可以使用 try/catch 块来捕获异步操作中的异常。 async function myAsyncFunction() { try { const result await new Promise((resolve) { resolve(Hello, world!); }); } catch (e) { console.error(Get exception: ${e}); }}
myAsyncFunction();
2、 单次 I/O 任务开发指导
Promise 和 async/await 提供异步并发能力适用于单次 I/O 任务的场景开发本文以使用异步进行单次文件写入为例来提供指导。
1. 实现单次 I/O 任务逻辑。 import fs from ohos.file.fs;
async function write(data: string, filePath: string) { let file await fs.open(filePath, fs.OpenMode.READ_WRITE); fs.write(file.fd, data).then((writeLen) { fs.close(file); }).catch((err) { console.error(Failed to write data. Code is ${err.code}, message is ${err.message}); })}
2. 采用异步能力调用单次 I/O 任务。示例中的 filePath 的获取方式请参见获取应用文件路径。 let filePath ...; // 应用文件路径write(Hello World!, filePath).then(() { console.info(Succeeded in writing data.);})
