Flutter/Dart第21天:Dart异步编程(Future/Stream)
Dart官方文档:https://dart.dev/language/async
重要说明:本博客基于Dart官网文档,但并不是简单的对官网进行翻译,在覆盖核心功能情况下,我会根据个人研发经验,加入自己的一些扩展问题和场景验证。
Future处理
我们有2种方式编写Future异步代码:
- 使用
async
和wait
关键字 - 使用Future API(https://dart.dev/guides/libraries/library-tour#future)
推荐使用async
和wait
关键字,让异步代码看起来和同步代码一样。
如下代码样例:wait
关键字等待异步函数返回结果,它必须在async
函数中。
Future<void> checkVersion() async {
var version = await lookUpVersion();
var exitCode = await findExitCode();
// ......
await flushThenExit(exitCode);
}
可以用try
、catch
和finally
关键字处理错误和清理代码:
try {
version = await lookUpVersion();
} catch (e) {
// React to inability to look up the version
} finally {
// Clean code
}
申明异步函数
使用async
修饰一个函数体,这个函数就是异步函数,它的返回结果是一个Future<T>
,当函数无需返回结果时,返回结果为Future<void>
:
Future<String> lookUpVersion async {
// ......
return '1.0.1';
}
Future<void> doSomething() {
// ......
}
Stream处理
同样的,我们也有2种方式编写Stream代码:
- 在异步循环使用
async
异步关键字(await for
) - 使用Stream API(https://dart.dev/guides/libraries/library-tour#stream)
推荐使用async
关键字,异步循环的形式如下:
await for (varOrType identifier in expression) {
// ......
}
在上诉异步循环形式中,expression
的值为一个Stream类型,异步循环的执行过程如下:
- 等待Stream产出一个值(即触发循环执行)
- 设置identifier变量值,执行循环体逻辑
- 重复上面2步,直到Stream关闭(即循环结束)
我们可以通过break
或者return
语句,退出循环,从而中断监听Stream生产的值。
同样的,异步循环的函数,必须使用async
关键字修饰。如下所示,main()
函数体使用了await for
异步循环,则函数必须使用async
修饰:
void main() async {
// ......
await for (final request in requestServer) {
handleRequest(request);
}
// ......
}
最后
- 第4课对异步编程文档(Future和async/await):https://ntopic.cn/p/2023092901
- 其他更多关于异步编程信息,请求参考异步包
dart:async
(https://dart.dev/guides/libraries/library-tour#dartasync---asynchronous-programming)
我的本博客原地址:https://ntopic.cn/p/2023111801
本文作者:奔跑的蜗牛,转载请注明原文链接:https://ntopic.cn