Dart 异步编程 Async/Await-JavaScript中文网-JavaScript教程资源分享门户

在现代Web开发和服务器端应用中，异步编程是一个非常重要的概念。它允许程序在等待某些操作完成时执行其他任务，从而提高效率和响应性。Dart语言通过 async 和 await 关键字提供了强大的异步编程支持。

Dart 中的 Future 和 Stream

在深入讲解 async 和 await 之前，我们先来了解一下 Dart 中的 Future 和 Stream 类型。这两个类型是 Dart 异步编程的核心。

Future

Future 表示一个可能尚未完成的操作的结果。你可以将 Future 理解为一个承诺，它保证在未来某个时间点会提供一个结果或抛出一个异常。例如，网络请求、文件读写等通常都是异步操作，它们的结果会被封装在一个 Future 对象中。

创建 Future

你可以使用 Future 构造函数来创建一个新的 Future 实例：

Future<int> future = Future(() {
  return 42;
});

在这个例子中，future 将会在稍后返回整数值 42。

处理 Future 结果

可以使用 .then() 方法来处理 Future 完成后的结果：

future.then((value) {
  print('Future completed with value $value');
}).catchError((error) {
  print('An error occurred: $error');
});

.then() 方法接收一个回调函数，当 Future 完成时该回调函数将被调用，并且传递 Future 的结果作为参数。如果 Future 抛出异常，则可以使用 .catchError() 方法捕获并处理这些异常。

Stream

Stream 是一种特殊类型的 Iterable，用于表示数据流。它可以连续地发送数据项，直到流结束或发生错误。Stream 在处理实时数据（如用户输入、传感器数据等）时特别有用。

创建 Stream

你可以通过多种方式创建 Stream，包括使用 StreamController 或者从集合生成 Stream：

Stream<int> createStream() async* {
  for (int i = 0; i < 5; i++) {
    await Future.delayed(Duration(seconds: 1));
    yield i;
  }
}

在这个例子中，createStream 函数会每秒发送一次数字，总共发送五次。

处理 Stream 数据

可以使用 .listen() 方法来监听 Stream 并处理接收到的数据：

createStream().listen((data) {
  print('Received data: $data');
}, onError: (err) {
  print('Error occurred: $err');
}, onDone: () {
  print('Stream is done');
});

.listen() 方法接受三个可选参数：onData 回调函数用于处理接收到的数据，onError 用于处理错误，onDone 用于处理流结束的情况。

使用 async/await 进行异步编程

async 和 await 是 Dart 提供的简化异步编程的方法，使得异步代码看起来更像同步代码。

定义异步函数

使用 async 关键字定义一个异步函数：

// www.javascriptcn.com code example
Future<void> fetchData() async {
  var data = await fetchSomeData();
  print(data);
}

Future<String> fetchSomeData() async {
  await Future.delayed(Duration(seconds: 2)); // 模拟延迟
  return "Some Data";
}

在这个例子中，fetchData 函数是一个异步函数，它调用了另一个异步函数 fetchSomeData 来获取数据。await 关键字确保在继续执行之前等待 fetchSomeData 返回结果。

处理异步错误

在异步函数中，可以通过 try-catch 结构来处理可能出现的错误：

Future<void> fetchDataWithTryCatch() async {
  try {
    var data = await fetchSomeData();
    print(data);
  } catch (e) {
    print('Caught an error: $e');
  }
}

这里，如果 fetchSomeData 抛出异常，catch 块将会捕获并处理这个异常。

同时执行多个异步操作

有时你可能需要同时执行多个异步操作。Dart 提供了 Future.wait 方法来帮助你管理这种情况：

// www.javascriptcn.com code example
Future<void> fetchMultipleData() async {
  List<Future<String>> futures = [
    fetchSomeData(),
    fetchMoreData()
  ];

  List<String> results = await Future.wait(futures);

  print(results);
}

Future<String> fetchMoreData() async {
  await Future.delayed(Duration(seconds: 3));
  return "More Data";
}

在这个例子中，Future.wait 接收一个 Future 列表，并返回一个包含所有 Future 结果的列表。这使得你可以方便地等待多个异步操作完成。

通过上述介绍，你应该对 Dart 中的异步编程有了一个全面的理解。Future 和 Stream 类型以及 async 和 await 关键字的使用，为构建高效、响应迅速的应用提供了强有力的工具。