Flutter中同步与异步

一,同步/异步的理解

1,await:同步机制

同步操作会阻止其他操作执行,直到完成为止。同步就好比打电话一样,打电话时都是一个人在说另一个人听,一个人在说的时候另一个人等待,等另一个人说完后再接着说。

2,async:异步机制

异步操作一旦启动,就允许其他操作在其完成之前执行。异步就好比发邮件一样,收件人和发件人都不需要相互等待,发件人写完邮件的时候简单的点个发送就可以了,收件人收到后就可以阅读啦,收件人和发件人不需要相互依赖、不需要相互等待。

二,Dart中同步/异步。

async 和 await 关键字构成了异步编程的基础,它们极大地简化了异步操作的处理流程。async 关键字用于声明一个函数为异步函数,这意味着该函数的执行可能不会立即完成,并且会返回一个 Future 对象。

1,Future 是 Dart 中的一个核心类,代表一个可能在未来某个时间点返回结果的计算。

当在 async 函数内部遇到 await 关键字时,执行流程会暂停,直到 await 后面的异步操作完成。

这种暂停并不会阻塞整个线程,而是允许 Dart 的事件循环继续处理其他事件,如用户交互或动画,从而保持应用的响应性。

2,使用 await 的优势在于它能够让异步代码的逻辑流程更加直观和清晰。

开发者不再需要通过嵌套回调(俗称“回调地狱”)来处理异步操作的结果,而是可以以近似同步的方式编写代码,使得逻辑更容易理解和维护。

3,async 和 await 在错误处理方面也提供了便利。

在 async 函数中,可以使用传统的 try-catch 结构来捕获异步操作中抛出的异常,这比处理 Future 的 catchError 方法更加直观。

三,Flutter中同步/异步的使用

1,StreamBuilder/FutureBuilder

在 Flutter 中,StreamBuilderFutureBuilder 都是用于处理异步数据源的常用组件。它们允许你在等待异步操作完成时更新 UI。尽管它们的功能类似,但它们适用于不同的异步数据源类型。

1.1,FutureBuilder

FutureBuilder 用于处理 Future 类型的异步数据源。Future 表示一个将来可能会完成的单一异步操作,例如一次性网络请求。

基本用法
  • 适用场景: 当你有一个一次性的异步操作,例如从网络加载数据,执行数据库查询等。

  • 构造函数参数:

    • future: 一个 Future 对象,表示要等待的异步操作。

    • builder: 一个函数,构建UI,并根据 Future 的状态来更新UI。

      import 'package:flutter/material.dart';class MyFutureBuilder extends StatelessWidget {Future<String> fetchData() async {await Future.delayed(Duration(seconds: 2)); // 模拟网络延迟return 'Hello, FutureBuilder!';}@overrideWidget build(BuildContext context) {return Scaffold(appBar: AppBar(title: Text('FutureBuilder Example')),body: Center(child: FutureBuilder<String>(future: fetchData(),builder: (BuildContext context, AsyncSnapshot<String> snapshot) {if (snapshot.connectionState == ConnectionState.waiting) {return CircularProgressIndicator();} else if (snapshot.hasError) {return Text('Error: ${snapshot.error}');} else {return Text('Result: ${snapshot.data}');}},),),);}
      }void main() => runApp(MaterialApp(home: MyFutureBuilder()));

      1.2,StreamBuilder

      StreamBuilder 用于处理 Stream 类型的异步数据源。Stream 表示一系列的异步事件或数据,例如连续的传感器数据、WebSocket 数据等。

      基本用法
    • 适用场景: 当你有多个异步数据或事件的流,例如实时更新的数据、传感器数据等。

    • 构造函数参数:

      • stream: 一个 Stream 对象,表示要监听的异步数据流。

      • builder: 一个函数,构建UI,并根据 Stream 的状态和数据来更新UI。

        import 'dart:async';
        import 'package:flutter/material.dart';class MyStreamBuilder extends StatelessWidget {Stream<int> counterStream() async* {for (int i = 0; i < 10; i++) {await Future.delayed(Duration(seconds: 1));yield i;}}@overrideWidget build(BuildContext context) {return Scaffold(appBar: AppBar(title: Text('StreamBuilder Example')),body: Center(child: StreamBuilder<int>(stream: counterStream(),builder: (BuildContext context, AsyncSnapshot<int> snapshot) {if (snapshot.connectionState == ConnectionState.waiting) {return CircularProgressIndicator();} else if (snapshot.hasError) {return Text('Error: ${snapshot.error}');} else if (!snapshot.hasData) {return Text('No data');} else {return Text('Counter: ${snapshot.data}');}},),),);}
        }
        void main() => runApp(MaterialApp(home: MyStreamBuilder()));

        1.3,区别总结

      • 数据源类型:

        • FutureBuilder:处理一次性异步操作的 Future

        • StreamBuilder:处理连续异步数据流的 Stream

      • 更新机制:

        • FutureBuilder:在 Future 完成或失败后构建一次 UI。

        • StreamBuilder:每次 Stream 发送新数据或状态变化时更新 UI。

      • 适用场景:

        • FutureBuilder:适用于单次的异步操作,例如网络请求、数据库查询等。

        • StreamBuilder:适用于多次的异步数据更新,例如实时数据、传感器数据、WebSocket 数据等。

          2,Future.wait/Future.any

          2.1,Future.wait

          Future.wait 等待所有提供的 Future 对象完成,并在所有 Future 都完成后返回一个包含每个 Future 结果的列表。如果任何一个 Future 抛出异常,则 Future.wait 会返回第一个抛出的异常。

          用法
        • 适用场景: 当你有多个并发的异步任务,并且需要等待所有任务都完成后再继续执行后续操作。

          import 'dart:async';void main() async {print('Start');Future<int> task1 = Future.delayed(Duration(seconds: 2), () => 1);Future<int> task2 = Future.delayed(Duration(seconds: 3), () => 2);Future<int> task3 = Future.delayed(Duration(seconds: 1), () => 3);List<int> results = await Future.wait([task1, task2, task3]);print('Results: $results'); // [1, 2, 3]print('End');
          }

          2.2,Future.any

          Future.any 等待提供的 Future 对象中第一个完成的任务,并返回该任务的结果。如果所有 Future 都抛出异常,则 Future.any 会返回最后一个抛出的异常。

          用法
        • 适用场景: 当你有多个并发的异步任务,并且只需要其中任何一个任务完成后就继续执行后续操作。

          import 'dart:async';void main() async {print('Start');Future<int> task1 = Future.delayed(Duration(seconds: 2), () => 1);Future<int> task2 = Future.delayed(Duration(seconds: 3), () => 2);Future<int> task3 = Future.delayed(Duration(seconds: 1), () => 3);int result = await Future.any([task1, task2, task3]);print('First completed result: $result'); // 3print('End');
          }

          在这个示例中,Future.any 会在 task3 完成后立即返回结果,因为 task3 是最先完成的任务。

          在这个示例中,Future.any 会在 task3 完成后立即返回结果,因为 task3 是最先完成的任务。

          2.3,区别总结

        • 行为方式:

          • Future.wait 等待所有 Future 对象完成,并返回所有结果。

          • Future.any 等待第一个完成的 Future 对象,并返回其结果。

        • 错误处理:

          • Future.wait 如果任何一个 Future 抛出异常,则返回第一个抛出的异常。

          • Future.any 如果所有 Future 都抛出异常,则返回最后一个抛出的异常。

        • 适用场景:

          • Future.wait 适用于需要所有并发任务都完成后再处理结果的场景。

          • Future.any 适用于只需要其中任何一个任务完成即可继续执行的场景。

            2.4,实践中的应用场景

            使用 Future.wait

            假设你在开发一个应用,需要同时发起多个网络请求,只有在所有请求完成后才能继续处理响应数据。这时你可以使用 Future.wait

            import 'dart:async';void main() async {Future<String> fetchUserData() async {await Future.delayed(Duration(seconds: 2));return 'User data';}Future<String> fetchOrders() async {await Future.delayed(Duration(seconds: 3));return 'Orders';}Future<String> fetchSettings() async {await Future.delayed(Duration(seconds: 1));return 'Settings';}print('Fetching data...');List<String> results = await Future.wait([fetchUserData(),fetchOrders(),fetchSettings(),]);print('All data fetched: $results');
            }
            使用 Future.any

            假设你在开发一个应用,需要从多个服务器中获取数据,只要任何一个服务器返回数据即可。这时你可以使用 Future.any

            import 'dart:async';void main() async {Future<String> fetchFromServer1() async {await Future.delayed(Duration(seconds: 2));return 'Data from server 1';}Future<String> fetchFromServer2() async {await Future.delayed(Duration(seconds: 3));return 'Data from server 2';}Future<String> fetchFromServer3() async {await Future.delayed(Duration(seconds: 1));return 'Data from server 3';}print('Fetching data...');String result = await Future.any([fetchFromServer1(),fetchFromServer2(),fetchFromServer3(),]);print('First data fetched: $result');
            }

            3,Future.doWhile/Future.forEach

            3.1,Future.doWhile

            Future.doWhile 用于执行一个异步循环,直到条件不满足为止。循环体中的每次迭代是异步的,并且需要返回一个 Future<bool>,表示是否继续循环。

            用法
          • 适用于需要重复执行异步操作,直到某个条件不再满足的场景。

            import 'dart:async';void main() async {int counter = 0;print('Start');await Future.doWhile(() async {counter++;print('Counter: $counter');await Future.delayed(Duration(seconds: 1)); // 模拟异步操作return counter < 5; // 继续循环直到 counter >= 5});print('End');
            }

            3.2,Future.forEach

            Future.forEach 用于对集合中的每个元素执行异步操作。它依次执行每个元素的异步操作,等待当前操作完成后再执行下一个操作。

            用法
          • 适用于需要对集合中的每个元素执行异步操作的场景。

            import 'dart:async';void main() async {List<int> numbers = [1, 2, 3, 4, 5];print('Start');await Future.forEach(numbers, (number) async {print('Processing number: $number');await Future.delayed(Duration(seconds: 1)); // 模拟异步操作});print('End');
            }

            3.3,区别总结

          • 控制流方式:

            • Future.doWhile:用于执行一个异步循环,直到条件返回 false 为止。适合在不知道具体迭代次数的情况下执行重复的异步操作。

            • Future.forEach:用于对集合中的每个元素执行异步操作,适合在知道具体迭代次数的情况下对集合进行异步处理。

          • 返回类型:

            • Future.doWhile:接受一个返回 Future<bool> 的函数作为参数。

            • Future.forEach:接受一个返回 Future<void> 的函数作为参数。

          • 终止条件:

            • Future.doWhile:循环的终止条件由函数返回的布尔值决定。

            • Future.forEach:循环的终止条件是集合中所有元素都处理完毕。

          • 4,Future异常处理。

            Flutter 和 Dart 提供了几种方法来捕获和处理 Future 异常,包括使用 try-catch 语句、catchError 方法以及在异步函数中处理异常。

            4.1,try-catch

            import 'dart:async';Future<void> fetchData() async {try {await Future.delayed(Duration(seconds: 2));throw Exception('Failed to fetch data'); // 模拟异常} catch (e) {print('Caught an exception: $e');}
            }void main() async {await fetchData();print('Done');
            }

            4.2,catchError

            catchError 方法需要一个回调函数,该函数接收异常作为参数。

            import 'dart:async';Future<void> fetchData() {return Future.delayed(Duration(seconds: 2)).then((_) {throw Exception('Failed to fetch data'); // 模拟异常}).catchError((e) {print('Caught an exception: $e');});
            }void main() async {await fetchData();print('Done');
            }
            4.2.1,使用 then 和 catchError 组合

            thencatchError 方法可以组合使用,以便在 Future 完成时处理结果,并在出现异常时进行错误处理。

            import 'dart:async';Future<void> fetchData() {return Future.delayed(Duration(seconds: 2)).then((_) {throw Exception('Failed to fetch data'); // 模拟异常}).catchError((e) {print('Caught an exception: $e');});
            }void main() async {await fetchData();print('Done');
            }

            4.3,在多个 Future 中处理异常
             

            import 'dart:async';Future<void> task1() async {await Future.delayed(Duration(seconds: 1));throw Exception('Error in task 1');
            }Future<void> task2() async {await Future.delayed(Duration(seconds: 2));throw Exception('Error in task 2');
            }void main() async {try {await Future.wait([task1().catchError((e) {print('Caught an exception in task 1: $e');}), task2().catchError((e) {print('Caught an exception in task 2: $e');})]);} catch (e) {print('Caught an exception: $e');}print('Done');
            }

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/bicheng/25127.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

【Git】远程操作 -- 详解

一、理解分布式版本控制系统 我们目前所说的所有内容&#xff08;工作区、暂存区、版本库等等&#xff09;都是在本地&#xff0c;也就是在我们的笔记本或者计算机上。而我们的 Git 其实是分布式版本控制系统。 上面这段话是什么意思呢&#xff1f; 可以简单理解为&#xff1…

java算法篇之二分查找的公共函数

Arrays.binarySearch 方法的底层实现是使用经过优化的二分查找算法。以下是大致的二分查找算法实现步骤&#xff1a; 首先&#xff0c;确定搜索范围的起始索引 low 和结束索引 high&#xff0c;它们分别初始化为数组的起始位置和结束位置。在每一轮循环中&#xff0c;计算中间…

node-mysql中占位符?的使用

要mysql执行的命令串如果是固定的&#xff0c;那么不需要使用占位符&#xff0c;如果其中的一些参数允许在执行前可自由设定&#xff0c;那么使用占位符就很必要&#xff0c;这样你可以不需要由自己来拼接出一个完整的执行串&#xff0c;只需要在执行串模板上将占位符的参数设置…

新型数据库技术一览

新型数据库技术是信息技术领域中不断发展和创新的一部分&#xff0c;它们旨在解决传统数据库系统面临的挑战&#xff0c;如大数据量的处理、实时分析、云服务集成、数据安全性和多模型支持等。以下是一些当前备受关注的新型数据库技术&#xff1a; NoSQL数据库&#xff1a; 非…

USB (2)

USB transaction 以2.0的枚举过程为例。 首先是TOKEN TRANSACTION&#xff0c;其次是DATA TRANSACTION&#xff0c;再次是Handshake Transaction。 上面的SETUP TRANSACTION是TOKEN TRANSACTION的一种。另外三种是OUT, IN, SOF。 在每个TRANSACTION中又包含了3个STAGE&#x…

在Windows中安装MinGW-w64

在Windows中安装MinGW-w64 总共两步&#xff1a; 下载mingw文件&#xff0c;官网较慢&#xff0c;有国内镜像解压下载的文件&#xff0c;放到想要安装的位置&#xff0c;然后在环境变量里面新建一个值&#xff0c;添加/bin目录 以前安装mingw是可以直接下载一个.exe安装文件…

如何在恢复出厂设置后从 Android 恢复照片

在某些情况下&#xff0c;您可能会考虑将 Android 设备恢复出厂设置。需要注意的是&#xff0c;恢复出厂设置后&#xff0c;所有设置、用户数据甚至应用程序数据都将被清除。因此&#xff0c;如果您将 Android 设备恢复出厂设置&#xff0c;甚至在里面留下了一些珍贵的照片&…

Debian13将正式切换到基于内存的临时文件系统

以前的内存很小&#xff0c;旅行者一号上的计算机内存只有68KB&#xff0c;现在的内存可以几十G&#xff0c;上百G足够把系统全部装载在内存里运行&#xff0c;获得优异的性能和极速响应体验。 很多小型系统能做到这一点&#xff0c;Linux没有那么激进&#xff0c;不过Debian …

java判断对象是否还在被引用

1、代码取消强引用后&#xff0c;gc回收对象 public static void main(String[] args) {Object obj new Object();WeakReference<Object> weakRef new WeakReference<>(obj);System.out.println(weakRef.get());obj null; // 取消强引用,后续gc会被回收,如果不…

1.基于-LABVIEW的自动售卖机开发(前面板)

1.项目简介 随着科技的进步和人们生活节奏的加快&#xff0c;自动售卖机在日常生活中扮演着越来越重要的角色。它们不仅提高了商品购买的便捷性&#xff0c;还节省了人力成本。为了实现更加智能化和高效的售卖服务&#xff0c;本项目旨在开发一款基于LabVIEW平台的自动售卖机系…

SpringBoot+Vue免税商品优选购物商城(前后端分离)

技术栈 JavaSpringBootMavenMySQLMyBatisVueShiroElement-UI 角色对应功能 用户商家 功能截图

Mysql学习(六)——函数

提示&#xff1a;文章写完后&#xff0c;目录可以自动生成&#xff0c;如何生成可参考右边的帮助文档 文章目录 三、函数3.1 字符串函数3.2 数值函数3.3 日期函数3.4 流程函数 三、函数 函数是指一段可以直接被另一段程序调用的程序或代码。 3.1 字符串函数 MySQL中内置了很…

论文浅尝 | THINK-ON-GRAPH:基于知识图谱的深层次且可靠的大语言模型推理方法...

笔记整理&#xff1a;刘佳俊&#xff0c;东南大学硕士&#xff0c;研究方向为知识图谱 链接&#xff1a;https://arxiv.org/pdf/2307.07697.pdf 1. 动机 本文是IDEA研究院的工作&#xff0c;这篇工作将知识图谱的和大语言模型推理进行了结合&#xff0c;在每一步图推理中利用大…

Y2期末测试

目录 总结&#xff1a;题目1.划分区间2.序列操作题目描述&#xff1a;题解&#xff1a;代码&#xff1a; 3.划分区间题目描述&#xff1a;题解&#xff1a;代码&#xff1a; 4.数字匹配题目描述&#xff1a;题解&#xff1a;代码&#xff1a; 总结&#xff1a; 本次模拟未达到…

[图解]建模相关的基础知识-06

1 00:00:00,790 --> 00:00:03,480 下一个概念&#xff0c;就是基数的概念 2 00:00:04,390 --> 00:00:11,560 cardinality&#xff0c;表示有限集合中元素的数量 3 00:00:12,200 --> 00:00:14,790 我们可以用一个井号 4 00:00:14,800 --> 00:00:18,320 在前面表示…

数据结构--递归和数组

个人介绍 hello hello~ &#xff0c;这里是 code袁~&#x1f496;&#x1f496; &#xff0c;欢迎大家点赞&#x1f973;&#x1f973;关注&#x1f4a5;&#x1f4a5;收藏&#x1f339;&#x1f339;&#x1f339; &#x1f981;作者简介&#xff1a;一名喜欢分享和记录学习的…

10.邮票问题

上海市计算机学会竞赛平台 | YACSYACS 是由上海市计算机学会于2019年发起的活动,旨在激发青少年对学习人工智能与算法设计的热情与兴趣,提升青少年科学素养,引导青少年投身创新发现和科研实践活动。https://www.iai.sh.cn/problem/625 题目描述 有四种面值的邮票,分别是 …

使用 Django 创建 App

文章目录 步骤 1&#xff1a;创建 Django 项目步骤 2&#xff1a;创建 App步骤 3&#xff1a;配置 App步骤 4&#xff1a;编写代码步骤 5&#xff1a;运行服务器 在 Django 中&#xff0c;App 是组织代码的基本单元&#xff0c;它可以包含模型、视图、模板等组件&#xff0c;帮…

树1----7-3 列出叶结点

对于给定的二叉树&#xff0c;本题要求你按从上到下、从左到右的顺序输出其所有叶结点。 输入格式&#xff1a; 首先第一行给出一个正整数 n&#xff08;≤10&#xff09;&#xff0c;为树中结点总数。树中的结点从 0 到 n−1 编号。随后 n 行&#xff0c;每行给出一个对应结…

Web前端编程网站:探索编程世界的新窗口

Web前端编程网站&#xff1a;探索编程世界的新窗口 在数字化时代的浪潮中&#xff0c;Web前端编程网站如雨后春笋般涌现&#xff0c;为编程爱好者们打开了一扇探索编程世界的新窗口。这些网站不仅提供了丰富的学习资源&#xff0c;还搭建了一个交流与分享的平台&#xff0c;让…