简介
Dart 添加了一些新的语言特性用于支持异步编程。最通常使用的特性是 async 方法和 await 表达式。Dart 库 大多方法返回 Future 和 Stream 对象。这些方法是异步的:它们在设置一个可能的耗时操作(比如 I/O 操 作)之后返回，而无需等待操作完成
Future对象
当你需要使用 Future 来表示一个值时，你有两个选择。
-
使用 async 和 await
-
使用 Future API
同样的，当你需要从 Stream 获取值的时候，你有两个选择。
-
使用 async 和一个异步的 for 循环 ( await for )
-
使用 Stream API
使用 async 和 await 的代码是异步的，不过它看起来很像同步的代码。
比如这里有一段使用 await 等待一个 异步函数结果的代码:
await lookUpVersion()
要使用 await ，代码必须用 await 标记:
checkVersion() async {
var version = await lookUpVersion();
if (version == expectedVersion) {
// Do something.
} else {
// Do something else.
}
}
你可以使用 try , catch , 和 finally 来处理错误并精简使用了 await 的代码。
try {
server = await HttpServer.bind(InternetAddress.LOOPBACK_IP_V4, 4044);
} catch (e) {
// React to inability to bind to the port...
}
下面是就一个异步方法例子：
import 'dart:async';
void main() {
//耗时操作
checkVerson();
print('耗时的操作后面执行');
}
//返回的Future对象
//调用await的话，外面必须是异步的方法
checkVerson() async {
try {
await lookUpVersion();
} catch(e) {
print('捕捉出现的异常');
//handle exception
}
}
Future<String> lookUpVersion() {
var timer;
timer = Timer.periodic(
const Duration(seconds: 5), (Void) {
print('定时器定时5秒钟执行');
});
}
执行的结果,定时器每隔5秒实行一次：
耗时的操作后面执行
定时器定时5秒钟执行
定时器定时5秒钟执行
定时器定时5秒钟执行
定时器定时5秒钟执行
定时器定时5秒钟执行
执行结果表明，前面的耗时操作无需等待操作完成，不会影响后面的执行。
声明异步函数
一个异步函数是一个由 async 修饰符标记的函数。虽然一个异步函数可能在操作上比较耗时，但是它可以立即 返回-在任何方法体执行之前。
//正常的几异步函数
checkVersion() async {
// ...
}
//第二种只有一个表达式简写
lookUpVersion() async => {表达式};
在函数中添加关键字 async 使得它返回一个 Future 。
比如，考虑一下这个同步函数，它将返回一个字符串。
//同步方法
String lookUpVersionSync() => '1.0.0';
如果你想更改它成为异步方法-因为在以后的实现中将会非常耗时-它的返回值是一个Future 。
//方法后面使用async
Future<String> lookUpVersion() async => '1.0.0';
注意：
- 函数体不需要使用 Future API ，如果必要的话 Dart 将会自己创建 Future 对象。
使用带 future 的 await 表达式
一个 await 表达式具有以下形式：
await expression
在异步方法中你可以使用 await 多次。比如，下列代码为了得到函数的结果一共等待了三次。
var entrypoint = await findEntrypoint();
var exitCode = await runExecutable(entrypoint, args);
await flushThenExit(exitCode);
在 await 表达式 中：
-
表达式的值通常是一个Future对象
-
如果不是，那么这个值会自动转为 Future 。
-
这个Future对象表明了表达式应该返回一个对象。
-
await表达式的值就是返回的一个对象。在对象可用之前，await表达式将会一直处于暂停状态。
如果 await 没有起作用，请确认它是一个异步方法。比如，在你的 main() 函数里面使用 await ， main() 的 函数体必须被 async 标记:
//在函数中使用了await，这个函数必须被async标记
main() async {
checkVersion();
print('In main: version is ${await lookUpVersion()}');
}
结合streams使用异步循环
一个异步循环具有以下形式:
await for (variable declaration in expression) {
// Executes each time the stream emits a value.
}
表达式 的值必须有Stream 类型(流类型)。执行过程如下:
-
在 stream 发出一个值之前等待
-
执行 for 循环的主体，把变量设置为发出的值。
-
重复 1 和 2，直到 Stream 关闭
如果要停止监听 stream ，你可以使用 break 或者 return 语句，跳出循环并取消来自stream 的订阅 。
如果一个异步 for 循环没有正常运行，请确认它是一个异步方法。 比如，在应用的 main() r 循环时，main() 的方法体必须被 async 标记。
//异步 for 循环执行必须在异步方法内
main() async {
...
await for (var request in requestServer) {
handleRequest(request);
}
...
}
网友评论