Flutter中Future和Stream关系

news/2025/3/16 21:09:42/
        Future和Stream类是Dart异步编程的核心。

        Future 表示一个不会立即完成的计算过程。与普通函数直接返回结果不同的是异步函数返回一个将会包含结果的 Future。该 Future 会在结果准备好时通知调用者。

        Stream 是一系列异步事件的序列。其类似于一个异步的 Iterable,不同的是,当你向 Iterable 获取下一个事件时它会立即给你,但是 Stream 则不会立即给你而是在它准备好时告诉你。

        Future和Stream的本质区别是:Future中的任务会加入下一轮事件循环,而Stream中的任务则是加入微任务队列。

Future 用于表示单个运算的结果,而 Stream 则表示多个结果的序列。
Stream中的执行异步的模式就是scheduleMicrotask。因为microtask的优先级又高于event。
所以,如果 microtask 太多就可能会对触摸、绘制等外部事件造成阻塞卡顿。

        一个Stream可以通过Stream.fromFuture方法将一个Future转换为Stream, 也可以通过Stream.fromFutures将多个Future添加到Stream中。

        Stream分为Single Subscription和Broadcast两种类型, 前者只允许订阅(listen)一次,后者允许多次订阅。

// 1. Single-Subscription
var data = [1, 2, '3.toString()', true, true, false, true, 6];
Stream stream = Stream.fromIterable(data).distinct();
stream.listen((event) => print('Liste1 -> Stream.fromIterable -> $event')).onDone(() => print('onDone1 -> Stream.fromIterable -> done 结束'));
stream  //报错.listen((event2) => print('Liste2 -> Stream.fromIterable -> $event2')).onDone(() => print('onDone2 -> Stream.fromIterable -> done 结束'));
// 2. Broadcast 所有数据被打印两次
var data = [1, 2, '3.toString()', true, true, false, true, 6];
Stream stream = Stream.fromIterable(data).distinct();
stream = stream.asBroadcastStream();
stream.listen((event) => print('Liste1 -> Stream.fromIterable -> $event')).onDone(() => print('onDone1 -> Stream.fromIterable -> done 结束'));
stream .listen((event2) => print('Liste2 -> Stream.fromIterable -> $event2')).onDone(() => print('onDone2 -> Stream.fromIterable -> done 结束'));

        通过StreamController向Stream中添加数据:

//1. 通过StreamController创建stream并添加数据(1)
StreamController<String> _streamControler = StreamController<String>();
_streamControler.stream.listen(onData:onData, onError: onError, onDone: onDone);
_streamControler.add(await getData());//2. 通过StreamController的Sink添加数据(2)
StreamController<String> _streamControl = StreamController<String>();
Sink _sink=_streamControler.sink;
_sink.add(await getData());

        通过StreamBuilder可以用来实现界面的异步构建,其作用类似于FutureBuilder。但StreamBuilder能力更强,可以等待多个异步事件完成,然后再执行Widget的构建。

StreamBuilder<List<String>>(stream: dataStream,initialData: ["none"],///这里的 snapshot 是数据快照的意思builder: (BuildContext context, AsyncSnapshot<List<String>> snapshot) {///获取到数据,为所欲为的更新 UIvar data = snapshot.data;return Container();});

http://www.ppmy.cn/news/1368023.html

相关文章

STL容器之string类

文章目录 STL容器之string类1、 什么是STL2、STL的六大组件3、string类3.1、string类介绍3.2、string类的常用接口说明3.2.1、string类对象的常见构造3.2.2、string类对象的容量操作3.2.3、string类对象的访问及遍历操作3.2.4、 string类对象的修改操作3.2.5、 string类非成员函…

uniapp实现多行文本溢出超过指定行数 展开 收起

一、组件封装 <template><view class"multiline"><view class"info"><view :class"{hide:!iSinfo}" :style"!iSinfo?computedStyle:"><view :style"{ color: textColor,fontWeight:fontWeight,font…

python给企微发消息

方法一&#xff1a;webhook方式。使用群机器人给企微群发消息 import requestsdef qwxsendmessage(msg):urlhttps://qyapi.weixin.qq.com/cgi-bin/webhook/send?key6c598840-804a-4eb5-a999-a023313 #url换成自己群机器人的webhookurldata{msgtype:text,text:{content:msg}}…

React入门之React_使用es5和es6语法渲染和添加class

React入门 //react的核心库 <script src"https://cdn.jsdelivr.net/npm/react17/umd/react.development.js"></script> //react操作dom的核心库&#xff0c;类似于jquery <script src"https://cdn.jsdelivr.net/npm/react-dom17/umd/react-dom.…

Codeforces Round 782 (Div. 2) E. AND-MEX Walk(思维+并查集)

原题链接&#xff1a;E. AND-MEX Walk 题目大意&#xff1a; 给出一张 n n n 个点 m m m 条边的无向图&#xff0c;边带有边权。 我们定义一条路径的价值为&#xff1a; 假设我们经过了 k k k 个点&#xff08;点和边都可重复经过&#xff09;&#xff0c;且按顺序经过的边…

存储过程基本了解

文章目录 介绍存储过程示例1. 目的2. 输入参数3. 输出参数4. 执行逻辑5. 返回值6. 示例用法7. 注意事项 存储过程的关键字有哪些简单实操 介绍 存储过程是一组预编译的SQL语句&#xff0c;以及流程控制语句&#xff0c;封装在数据库服务器中并可以被重复调用。它们可以接收参数…

2024/3/1 贪心

跳跳 跳跳&#xff01; - 洛谷 思路&#xff1a;从一个数组里面依次取出最大值和最小值&#xff0c;然后进行运算 完整代码&#xff1a; #include <bits/stdc.h> #define int long long #define PII std::pair<int,int> signed main() {int n;std::cin >>…

大数据智能化-长视频领域

随着数字化时代的到来&#xff0c;长视频领域的发展迎来了新的机遇和挑战。在这一背景下&#xff0c;大数据智能化技术的应用成为长视频行业提升用户体验、优化运营管理的重要手段之一。本文将从优爱腾3大长视频背景需求出发&#xff0c;分析静态资源CDN、视频文件存储与分发、…