返回首页 Dart 语言概览

异步的支持

Dart 添加了一些新的语言特性用于支持异步编程。最通常使用的特性是 async 方法和 await 表达式。Dart 库大多方法返回 FutureStream 对象。这些方法是异步的:它们在设置一个可能的耗时操作(比如 I/O 操作)之后返回,而无需等待操作完成

当你需要使用 Future 来表示一个值时,你有两个选择。

  • 使用 asyncawait
  • 使用 Future API

同样的,当你需要从 Stream 获取值的时候,你有两个选择。

  • 使用 async 和一个异步的 for 循环 (await for)
  • 使用 Stream API

使用 asyncawait 的代码是异步的,不过它看起来很像同步的代码。比如这里有一段使用 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() 函数里面使用awaitmain() 的函数体必须被 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 类型(流类型)。执行过程如下:

  1. 在 stream 发出一个值之前等待
  2. 执行 for 循环的主体,把变量设置为发出的值。
  3. 重复 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

上一篇: 库和可见性 下一篇: Isolates