在开发 Flutter 应用时，Dart 语言的异步编程模型可是个关键技能。今天咱们就来深入聊聊这个事儿，把 Future 和 Stream 在实际开发中遇到的常见困惑和性能瓶颈都给解决掉。
一、异步编程基础概念
在说 Future 和 Stream 之前，咱得先搞明白啥是异步编程。简单来说，异步编程就是在程序执行的时候，不会一直等着一个任务完成，而是可以同时去做其他事情。就好比你在烧水的时候，不用一直盯着水壶，你可以去干点别的，等水开了再回来处理。
在 Dart 里，异步编程主要通过 Future 和 Stream 来实现。Future 就像是一个承诺，它代表一个还没完成的操作，等操作完成了，就会返回一个结果。而 Stream 就像是一条水流，它可以持续地发送数据。
二、Future 的使用
2.1 基本用法
Future 是 Dart 里处理异步操作的一个重要工具。下面是一个简单的例子：
// Dart 技术栈
// 定义一个异步函数，返回一个 Future 对象
Future<String> fetchData() {
return Future.delayed(Duration(seconds: 2), () {
return 'Data fetched successfully';
});
}
void main() {
// 调用异步函数
fetchData().then((data) {
// 当 Future 完成时，执行这里的代码
print(data);
});
print('This line is printed before the data is fetched');
}
在这个例子里，fetchData 函数返回一个 Future 对象，它会在 2 秒后返回一个字符串。then 方法用来处理 Future 完成后的结果。注意看，print('This line is printed before the data is fetched') 会先执行，因为 fetchData 是异步操作，不会阻塞后续代码的执行。
2.2 错误处理
在异步操作中，可能会出现错误。我们可以使用 catchError 方法来处理这些错误。
// Dart 技术栈
Future<String> fetchData() {
return Future.delayed(Duration(seconds: 2), () {
throw Exception('Failed to fetch data');
});
}
void main() {
fetchData()
.then((data) {
print(data);
})
.catchError((error) {
// 处理错误
print('Error: $error');
});
}
这里，fetchData 函数抛出了一个异常，catchError 方法会捕获这个异常并打印错误信息。
2.3 多个 Future 串行执行
有时候，我们需要多个异步操作按顺序执行。可以使用 async 和 await 关键字来实现。
// Dart 技术栈
Future<String> fetchData1() {
return Future.delayed(Duration(seconds: 2), () {
return 'Data from first operation';
});
}
Future<String> fetchData2() {
return Future.delayed(Duration(seconds: 1), () {
return 'Data from second operation';
});
}
void main() async {
// 使用 await 等待第一个 Future 完成
String data1 = await fetchData1();
print(data1);
// 等待第二个 Future 完成
String data2 = await fetchData2();
print(data2);
}
在这个例子中，async 关键字把 main 函数变成了一个异步函数，await 关键字会暂停函数的执行，直到 Future 完成。
三、Stream 的使用
3.1 基本用法
Stream 可以持续地发送数据。下面是一个简单的 Stream 例子：
// Dart 技术栈
Stream<int> countStream(int max) async* {
for (int i = 0; i < max; i++) {
// 发送数据
yield i;
await Future.delayed(Duration(seconds: 1));
}
}
void main() {
Stream<int> stream = countStream(5);
// 监听 Stream
stream.listen((data) {
print(data);
});
}
在这个例子中，countStream 是一个异步生成器函数，它会每隔 1 秒发送一个整数。listen 方法用来监听 Stream 发送的数据。
3.2 错误处理
和 Future 一样，Stream 也可能会出现错误。可以使用 onError 回调来处理错误。
// Dart 技术栈
Stream<int> countStream(int max) async* {
for (int i = 0; i < max; i++) {
if (i == 2) {
// 抛出错误
throw Exception('Something went wrong');
}
yield i;
await Future.delayed(Duration(seconds: 1));
}
}
void main() {
Stream<int> stream = countStream(5);
stream.listen((data) {
print(data);
}, onError: (error) {
// 处理错误
print('Error: $error');
});
}
这里，当 i 等于 2 时，会抛出一个异常，onError 回调会捕获这个异常并打印错误信息。
3.3 操作 Stream
Stream 有很多操作方法，比如 map、where 等。下面是一个使用 map 方法的例子：
// Dart 技术栈
Stream<int> countStream(int max) async* {
for (int i = 0; i < max; i++) {
yield i;
await Future.delayed(Duration(seconds: 1));
}
}
void main() {
Stream<int> stream = countStream(5);
// 使用 map 方法对 Stream 中的数据进行处理
Stream<int> newStream = stream.map((data) {
return data * 2;
});
newStream.listen((data) {
print(data);
});
}
在这个例子中，map 方法把 Stream 中的每个数据都乘以 2。
四、应用场景
4.1 Future 的应用场景
- 网络请求：当你需要从服务器获取数据时，网络请求通常是异步的，使用 Future 可以很好地处理这种情况。
// Dart 技术栈
import 'package:http/http.dart' as http;
Future<String> fetchData() async {
var response = await http.get(Uri.parse('https://example.com/api/data'));
if (response.statusCode == 200) {
return response.body;
} else {
throw Exception('Failed to fetch data');
}
}
void main() {
fetchData().then((data) {
print(data);
}).catchError((error) {
print('Error: $error');
});
}
- 文件读写：读写文件也是一个异步操作，使用 Future 可以避免阻塞主线程。
// Dart 技术栈
import 'dart:io';
Future<String> readFile() async {
File file = File('example.txt');
return await file.readAsString();
}
void main() {
readFile().then((data) {
print(data);
}).catchError((error) {
print('Error: $error');
});
}
4.2 Stream 的应用场景
- 实时数据更新：比如股票价格、传感器数据等，这些数据会不断地更新，使用 Stream 可以实时获取这些数据。
// Dart 技术栈
import 'dart:math';
Stream<int> priceStream() async* {
Random random = Random();
while (true) {
yield random.nextInt(100);
await Future.delayed(Duration(seconds: 1));
}
}
void main() {
Stream<int> stream = priceStream();
stream.listen((price) {
print('Current price: $price');
});
}
- 用户输入：当用户在输入框中输入内容时，输入事件可以通过 Stream 来处理。
// Dart 技术栈
import 'dart:io';
void main() {
stdin.listen((event) {
String input = String.fromCharCodes(event);
print('You entered: $input');
});
}
五、技术优缺点
5.1 Future 的优缺点
- 优点：
- 简单易用，适合处理单个异步操作。
- 可以方便地处理错误。
- 缺点：
- 不适合处理持续的数据流。
- 对于多个异步操作的组合，代码可能会变得复杂。
5.2 Stream 的优缺点
- 优点：
- 可以处理持续的数据流，适合实时数据更新。
- 提供了丰富的操作方法，如
map、where等。
- 缺点：
- 相对复杂，需要更多的学习成本。
- 资源消耗可能会比较大，特别是在处理大量数据时。
六、注意事项
6.1 Future 注意事项
- 确保在使用
then方法时，处理可能出现的错误，避免程序崩溃。 - 避免在异步操作中进行长时间的计算，以免阻塞主线程。
6.2 Stream 注意事项
- 及时取消 Stream 的监听，避免内存泄漏。
- 注意 Stream 的背压问题，当数据发送速度过快时，可能会导致内存溢出。
七、文章总结
通过这篇文章，我们深入了解了 Dart 语言的异步编程模型，特别是 Future 和 Stream 的使用。Future 适合处理单个异步操作，而 Stream 适合处理持续的数据流。我们还介绍了它们的应用场景、优缺点和注意事项。在实际开发中，根据具体的需求选择合适的异步编程方式，可以提高程序的性能和稳定性。
评论