首页 游戏 软件 资讯 排行榜 专题
首页
编程语言
Dart异步编程详解从Future到Stream实战指南

Dart异步编程详解从Future到Stream实战指南

热心网友
63
转载
2026-05-07

何为异步支持

了解一下异步线程

说到异步编程,先得聊聊Dart这门语言的基础。一个核心事实是:Dart是单线程的。那么问题来了,既然是单线程,遇到像文件读写、网络请求这类“慢动作”操作时,线程岂不是会被“堵”在原地,导致用户界面卡成幻灯片?没错,正是为了避免这种阻塞局面,异步处理机制才应运而生,成为解决问题的关键钥匙。

免费影视、动漫、音乐、游戏、小说资源长期稳定更新! 👉 点此立即查看 👈

那么,这个单线程世界是如何高效运转的呢?这全靠其核心的消息循环机制。你可以把它想象成一个永不停歇的调度中心,管理着两个任务队列:一个是处理紧急、快速任务的“微任务队列”,另一个是处理常规、耗时任务的“事件队列”。

程序启动后,入口函数执行完毕,这个精巧的消息循环便正式开始工作了。它的规则很清晰:总是优先清空微任务队列,按照先进先出的顺序执行完毕,再去事件队列里取任务。每当事件队列的一个任务执行完后,它又会回过头去检查微任务队列……如此周而复始,就像一位不知疲倦的协调员,确保所有任务都能得到及时处理。

Dart中支持异步编程的方式

在Dart语言里,实现异步编程主要有两大支柱:

  • 异步核心类:Future和Stream。 它们是封装异步操作结果的主要载体。
  • 语法糖:asyncawait关键字。 这对搭档能让你以近乎同步的编码风格来书写异步逻辑,极大地提升了代码的可读性。

使用 async 和 await 进行异步处理

让我们通过一个简单的例子,来看看 asyncawait 是怎么工作的,以及新手常常在哪里“踩坑”。

假设有这样一个异步函数:

/*返回值为Future类型,即其返回值未来是一个String类型的值*/
/*async关键字声明该函数内部有代码需要延迟执行*/
getData() async {
    /*await关键字声明运算为延迟执行,然后return运算结果*/
    return await "This is a doubi";
}

看起来很简单,对吧?如果我们试图这样调用它:

String data = getData();

控制台立刻就会抛出错误。为什么会这样?关键在于理解 await 的实质。当一个返回值前有 await 标记时,它并不会直接返回你期待的具体值(比如String),而是返回一个包裹着这个“未来值”的“箱子”——也就是 Future 对象。把 Future 直接赋值给 String 类型,类型不匹配,报错自然就发生了。

所以,这里可以总结一个核心要点:在异步函数中,直接返回 await ... 的结果,实际上你拿到的是一个延迟计算的 Future 对象。

记住两件事,可以有效避免这类问题:一、await 关键字必须在被 async 修饰的函数内部使用;二、调用一个 async 函数,通常也需要用 await 来“解开”它返回的 Future

Future是什么

如果你熟悉Ja vaScript,可以把 Future 理解为Dart版的 Promise。它代表一个异步操作的最终结局——是成功携带着某个值,还是失败带着一个错误。

简单来说,Future 就是用来处理那些“将来才能知道结果”的事情。它抽象地表示一件“将要发生的事”,一旦这件事做完了,你就能从这个 Future 里取出结果。整个过程分为两步:首先,异步任务被安排进队列,方法会立即返回一个表示“未完成”状态的 Future;随后,等任务真正执行完毕,这个 Future 的状态会变为“已完成”,此时结果值就触手可及了。

至于如何拿到 Future 里的值,有两种主流方法:一是采用我们刚讨论过的 async/await 组合,让代码看起来更清爽;二是使用 Future 自带的API,通过 .then() 等方法来注册回调。

Future示例

理论说了不少,来看一段具体的代码,Future 的链条式调用是怎么执行的:

void doAsyncs() async{
    //then catchError whenComplete
    new Future(() => futureTask()) //  异步任务的函数
        .then((m) => "1-:$m") //   任务执行完后的子任务
        .then((m) => print('2-$m')) //  其中m为上个任务执行完后的返回的结果
        .then((_) => new Future.error('3-:error'))
        .then((m) => print('4-'))
        .whenComplete(() => print('5-')) //不是最后执行whenComplete,通常放到最后回调
        .catchError((e) => print('6-catchError:' + e), test: (Object o) {
      print('7-:' + o);
      return true; //返回true,会被catchError捕获
    })
        .then((_) => new Future.error('11-:error'))
        .then((m) => print('10-'))
        .catchError((e) => print('8-:' + e))
    ;
}
futureTask() {
    return Future.delayed(Duration(seconds: 5),() => "9-走去跑步");
}

这段代码的输出结果非常直观地展示了任务链、错误捕获与完成的执行顺序:

I/flutter: 2-1-:9-走去跑步

I/flutter: 5-

I/flutter: 7-:3-:error

I/flutter: 6-catchError:3-:error

I/flutter: 8-:11-:error

介绍一下Async/await

Dart中的 async/await 语法,其设计理念和用法与Ja vaScript如出一辙,目的都是为了提升异步代码的编写体验。

async/await消除callback hell

它们最显著的价值,就是能彻底拯救“回调地狱”。比较一下这两种写法,高下立判。没有 async/await 时,层层嵌套的回调让人望而生畏;而使用之后,代码变得几乎和同步逻辑一样清晰:

task() async {
   try{
    String id = await login("alice","******");
    String userInfo = await getUserInfo(id);
    await sa veUserInfo(userInfo);
    //执行接下来的操作
   } catch(e){
    //错误处理
    print(e);
   }
}

简单复习一下这两个关键字的角色:async 用来声明一个函数是异步的,被它标记的函数会返回一个 Future 对象。await 则用于等待一个 Future 完成,它“暂停”当前异步函数的执行(但不阻塞线程),直到等待的异步任务返回结果或抛出异常,然后才会继续往下走。记住,await 必须待在 async 函数的怀抱里。

Stream是什么

如果说 Future 代表一个“一次性”的异步结果,那么 Stream 就是用来处理“一连串”异步事件的。它的核心区别在于,可以接收并处理多个异步操作的结果(无论成功还是失败)。

当你需要执行一个可能多次产出数据或产生错误的异步任务时,Stream 就大显身手了。它允许你通过多次触发成功数据事件或错误事件,来持续传递信息。

Stream应用示例

Stream 在那些需要连续读取数据的场景下尤为常见,比如下载网络数据流、监听文件变化或读取大文件。下面这个例子,演示了如何用一个 Stream 来监听多个 Future 的结果序列:

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: (){
  print("完成");
});

运行这段代码,你会看到输出清晰地按顺序展示了每个异步任务的结果,包括其中间出现的错误:

I/flutter (17666): hello 1

I/flutter (17666): Error

I/flutter (17666): hello 3

来源:https://www.jb51.net/program/290690bi0.htm
免责声明: 游乐网为非赢利性网站,所展示的游戏/软件/文章内容均来自于互联网或第三方用户上传分享,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系youleyoucom@outlook.com。

最新APP

宝宝过生日
宝宝过生日
应用辅助 04-07
台球世界
台球世界
体育竞技 04-07
解绳子
解绳子
休闲益智 04-07
骑兵冲突
骑兵冲突
棋牌策略 04-07
三国真龙传
三国真龙传
角色扮演 04-07

热门推荐

安全用电指南正确连接集线器电源的方法
电脑教程
安全用电指南正确连接集线器电源的方法

集线器插电源必须严格遵循“先断电、再接线、后上电”的安全闭环流程 这可不是什么多余的步骤,而是电气工程领域的硬性规定。其依据清清楚楚地写在IEEE 802 3以太网标准和各大主流设备厂商的技术文档里。具体来说,如果给集线器带电插拔RJ45网线,虽然不一定立刻“冒烟”,但极有可能冲击到PHY芯片,造成

热心网友
05.07
C++实现图的拓扑排序Kahn算法详解与BFS核心源码解析
编程语言
C++实现图的拓扑排序Kahn算法详解与BFS核心源码解析

拓扑排序失败是算法实现中常见的问题。代码逻辑看似正确,但运行时可能陷入停滞或输出序列不完整,无法得到有效的拓扑顺序。这通常是由于图中存在环路依赖,导致算法无法找到入度为零的起始节点,从而使整个排序流程中断。 具体是哪些环节容易导致拓扑排序失败呢?我们来逐一分析排查。 为什么拓扑排序失败?先检查入度数

热心网友
05.07
2026年比特币减半倒计时:半价门票与投资须知全揭秘
web3.0
2026年比特币减半倒计时:半价门票与投资须知全揭秘

旧金山的秋天,向来是科技行业思潮涌动的季节。而今年10月13日至15日,这座城市将再次成为全球创新者的焦点——比特币世界碘伏大会2026即将在莫斯科尼西馆拉开帷幕。这场盛会不仅是前沿技术的风向标,更是连接顶尖创始人、投资者与科技领袖的关键网络节点。 大会亮点和主题 作为年度科技盛事,比特币世界碘伏大

热心网友
05.07
Sublime Text 4同步配置教程 如何安装Sync Settings插件
编程语言
Sublime Text 4同步配置教程 如何安装Sync Settings插件

想在 Sublime Text 4 里用上 Sync Settings 同步你的配置?这事儿能成,但得先跨过两道坎:插件版本得是 v3 0 或更高,同时你的 ST4 内核也得是比较新的版本。好消息是,2026 年主流发行版基本都达标了。很多朋友遇到的“装不上”、“菜单不出现”、“点了没反应”,十有八

热心网友
05.07
SATA硬盘连接主板必须按顺序接线吗
电脑教程
SATA硬盘连接主板必须按顺序接线吗

SATA硬盘连接主板:接口顺序真有讲究吗? 给主板接SATA硬盘,这事儿本身其实挺自由的。从物理层面看,只要接口对得上,线也插稳了,你随机找个孔插进去,电脑基本都能认出来。不过话说回来,如果你想追求更高的开机效率、更清晰的维护思路,那在接口选择上还真得花点小心思。一个核心建议是:把安装操作系统的那块

热心网友
05.07