作者 | 弗拉德

来源 | 弗拉德

异步

Dart 代码库中有大量返回Future或Stream对象的函数，这些函数都是异步的，它们会在耗时操作执行完毕前直接返回而不会等待耗时操作执行完毕。

async和await关键字用于实现异步编程，并且让你的代码看起来就像是同步的一样。

Future

可以通过下面两种方式，获得Future执行完成的结果：

• 使用async和await；

• 使用Future API；

使用async和await的代码是异步的，但是看起来有点像同步代码。例如，下面的代码使用await等待异步函数的执行结果。

await  lookUpVersion();

必须在带有async关键字的异步函数中使用 await：

Future  checkVersion() async {

var version = await  lookUpVersion();

// 使用 version 继续处理逻辑

}

尽管异步函数可以处理耗时操作，但是它并不会等待这些耗时操作完成，异步函数执行时会在其遇到第一个 await表达式的时候返回一个Future对象，然后等待await表达式执行完毕后继续执行。

使用try、catch以及finally来处理使用await导致的异常：

try {

version = await  lookUpVersion();

} catch (e) {

// 无法找到版本时做出的反应

}

你可以在异步函数中多次使用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关键字标识。

Future  main() async {

checkVersion();

print('在 Main 函数中执行：版本是 ${await lookUpVersion()}');

}

声明异步函数

定义异步函数只需在普通方法上加上async关键字即可。

将关键字async添加到函数并让其返回一个Future 对象。假设有如下返回String对象的方法：

String  lookUpVersion() => '1.0.0';

将其改为异步函数，返回值是Future：

Future<String> lookUpVersion() async => '1.0.0';

注意，函数体不需要使用Future API。如有必要，Dart会创建Future对象。

如果函数没有返回有效值，需要设置其返回类型为 Future<void>

Stream

Stream也是用于接收异步事件数据，和Future不同的是，它可以接收多个异步操作的结果（成功或失败）。 也就是说，在执行异步任务时，可以通过多次触发成功或失败事件来传递结果数据或错误异常。Stream常用于会多次读取数据的异步任务场景，如网络内容下载、文件读写等。举个例子：

Stream.fromFutures([

// 1秒后返回结果

Future.delayed(new  Duration(seconds: 1), () {

return  "hello 1";

}),

// 抛出一个异常

Future.delayed(new  Duration(seconds: 2),(){

throw  AssertionError("Error");

}),

// 3秒后返回结果

Future.delayed(new  Duration(seconds: 3), () {

return  "hello 3";

})

]).listen((data){

print(data);

}, onError: (e){

print(e.message);

},onDone: (){

  

});

上面的代码依次会输出：

hello 1

Error

hello 3