Dart 中的异步 API -- Future 和 Stream 以及 await/async

本文最后更新于 2021年4月4日晚上

本文主要讲 Dart 中的异步 API.

关于 Future 和 Stream 的概念

在 Dart 的帮助文档中有这两个.

实际上在 Dart 的异步编程中, 主要涉及的就是单线程模型和 Isolate. Future 和 Stream 只是异步编程工具 API.

Future API 和 async/await

A Future represents a computation that doesn’t complete immediately. Where a normal function returns the result, an asynchronous function returns a Future, which will eventually contain the result. The future will tell you when the result is ready.

Dart 中的异步编程, 当某个函数或方法返回 Future<T> 类型时, 可以使用两套机制来操作, 一套是 async/await, 一套是 Future 本身带的 API(then 和 catchError 等).


void main() {
  print('开始');
  execute();
  print('执行完');
  runApp(ListViewInsideScrollViewApp());
}

Future<void> execute() async {
  print('进入');
  final str = await delayOneSec();
  print(str);
}

Future<String> delayOneSec() {
  final oneSec = Duration(seconds: 1);
  return Future.delayed(oneSec, () {// 内部就是需要延时执行的代码
    return 'Hello world';
  });
}

// 输出顺序是:
开始
    进入
    	执行完
    		Hellow World

通过上面的代码来梳理 Future 和 async/await 的使用规则:

针对 Future 类型返回值的函数, 外界可以直接将它当作是异步代码调用(无需 await), 并假设执行到它的时候是直接往下走的(而实际上是在它内部遇到 await 后才将控制返回到调用函数继续执行)
await 只能在 async 函数或方法中使用.
如果使用 Future API 的话, 在 then 块中始终都要提供参数, 如果是 Future<void> , 则需要使用 _ 来表示参数.

和 Promise 的 API 类似, 在 Future 的 API 中可以将多个异步操作使用 then 来连接, 以达到顺序执行的目的(就相当于连续 await 多个异步操作一个道理, 只是写法不同罢了).

另外还可以等待多个异步操作结束, 这个就只能使用 Future 的异步 API wait 了:

1
2
3

Future.wait([expensiveA(), expensiveB(), expensiveC()])
    .then((List responses) => chooseBestResponse(responses, moreInfo))
    .catchError(handleError);

但任意一个异步操作抛出错误的话, 则就会进入 catchError 块中.

注意:

即便是最先完成的异步操作就产生了错误, 但进入错误捕捉块的时刻也是当最晚的一个异步操作执行完之后!

Stream

A stream is a sequence of asynchronous events. It is like an asynchronous Iterable—where, instead of getting the next event when you ask for it, the stream tells you that there is an event when it is ready.

Stream 就是异步事件流, 感觉和 Rx 有点类似.

在 Stream 中提供了许多操作符可供使用, 需要探索.

有两大类的 Stream: