异步的支持
Dart 添加了一些新的语言特性用于支持异步编程。最通常使用的特性是 async 方法和 await 表达式。Dart 库大多方法返回 Future 和 Stream 对象。这些方法是异步的:它们在设置一个可能的耗时操作(比如 I/O 操作)之后返回,而无需等待操作完成
当你需要使用 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...
}
声明异步函数
一个异步函数是一个由 async 修饰符标记的函数。虽然一个异步函数可能在操作上比较耗时,但是它可以立即返回-在任何方法体执行之前。
checkVersion() async {
// ...
}
lookUpVersion() async => /* ... */;
在函数中添加关键字 async 使得它返回一个 Future,比如,考虑一下这个同步函数,它将返回一个字符串。
String lookUpVersionSync() => '1.0.0';
如果你想更改它成为异步方法-因为在以后的实现中将会非常耗时-它的返回值是一个 Future 。
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 标记:
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() 方法中使用异步的 for 循环时,main() 的方法体必须被 async 标记。
main() async {
...
await for (var request in requestServer) {
handleRequest(request);
}
...
}
更多关于异步编程的信息,请看 dart:async 库部分的介绍。你也可以看文章 Dart Language Asynchrony Support: Phase 1 和 Dart Language Asynchrony Support: Phase 2, 和 the Dart language specification