Flutter中同步与异步

news2024/11/29 0:46:30

一，同步/异步的理解

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 中，StreamBuilder 和 FutureBuilder 都是用于处理异步数据源的常用组件。它们允许你在等待异步操作完成时更新 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!';
  }

  @override
  Widget 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;
    }
  }

  @override
  Widget 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'); // 3

  print('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 组合

            then 和 catchError 方法可以组合使用，以便在 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.coloradmin.cn/o/1804593.html

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈，一经查实，立即删除！

相关文章

OCP-042之：Oracle结构体系

OCP-042之：Oracle结构体系

1. Oracle结构体系 1.1 概述 1.1.1 版本 版本后缀所代表的含义 i：代表基于Internet架构的数据库，如9i g：代表基于grid（网格）的数据库，如11g grid的目的：降低成本，提高服务质量，简化管理 Storage Grid：ASM(automatic storage management)，继承了LVM技术，Oracl…
阅读更多...
Git【版本控制和Git的安装介绍】

Git【版本控制和Git的安装介绍】

01 【版本控制和Git的安装介绍】 工程设计领域中&#xff0c;使用“版本控制”管理工程蓝图的设计过程。在 IT 开发中也可以使用版本控制思想管理代码的版本迭代。 1.目的 协同修改&#xff1a;支持在服务器对同一个文件多人协同地修改&#xff1b; 数据备份&#xff1a;同时…
阅读更多...
java中的异常-异常处理（try、catch、finally、throw、throws）+自定义异常

java中的异常-异常处理（try、catch、finally、throw、throws）+自定义异常

一、概述 1、java程序员在编写程序时提前编写好对异常的处理程序&#xff0c;在程序发生异常时就可以执行预先设定好的处理程序&#xff0c;处理程序执行完之后&#xff0c;可以继续向后执行后面的程序 2、异常处理程序是在程序执行出现异常时才执行的 二、5个关键字 1、tr…
阅读更多...
11 gpio 与 pinctrl 子系统

11 gpio 与 pinctrl 子系统

1、GPIO 硬件结构 GPIO 是通用输入/输出端口的简称。GPIO 的引脚与外部硬件设备连接，可实现与外部通讯、控制外部硬件或者采集外部硬件数据的功能。 八种工作模式 GPIO_Mode_AIN 模拟输入 GPIO_Mode_IN_FLOATING 浮空输入 GPIO_Mode_IPD 下拉输入 GPIO_Mode_IPU 上拉输入GP…
阅读更多...
Hadoop笔记

Hadoop笔记

1.hadoop环境搭建&#xff0c;linux命令&#xff08;vi);2.分布式的基本概念&#xff0c;cap理论&#xff08;遵循此原则开发分布式数据库&#xff09;&#xff0c;hdfs,mapreduce&#xff1b;3.3.1&#xff1b;3.2重点&#xff1b;4.map&#xff0c;reduce过程&#xff0c;优缺…
阅读更多...
DBeaver无法连接Clickhouse，连接失败

DBeaver无法连接Clickhouse，连接失败

DBeaver默认下载的是0.2.6版本的驱动&#xff0c;但是一直连接失败&#xff1a; 报错提示 解决办法 点击上图中的Open Driver Configuration点击库 - 重置为默认状态在弹出的窗口中修改驱动版本号为0.2.4或者其他版本&#xff08;我没有试用过其他版本&#xff09;&#xff0…
阅读更多...
c++【入门】求圆环的面积

c++【入门】求圆环的面积

限制 时间限制 : 1 秒 内存限制 : 128 MB 题目 如下图所示的圆环铁片&#xff0c;中间是空心的&#xff0c;已知圆环外圆的半径是r1厘米&#xff08;如&#xff1a;10cm&#xff09;&#xff0c;内圆半径是r2厘米&#xff08;如&#xff1a;6cm&#xff09;&#xff0c;请编…
阅读更多...
stm32最小系统焊接调试总结

stm32最小系统焊接调试总结

stm32最小系统打板后，接下来开始焊接元器件，焊接元器件可以参考立创EDA焊接辅助工具。 图1 焊接辅助助手 焊接准备工具有，焊台，放大镜，元器件，镊子，焊锡膏，锡丝及万用表等。调节焊台温度到350-400摄氏度。焊接顺序是先焊接USB typec接口，5V电源，ldo，ch340，stm32芯片…
阅读更多...
标准发布实施 | 《村镇污水处理一体化集成装备技术规范》

标准发布实施 | 《村镇污水处理一体化集成装备技术规范》

根据《中华人民共和国标准化法》以及国家标准化管理委员会、民政部联合制定的《团体标准管理规定》&#xff0c;依据全国团体标准信息平台和《中华环保联合会团体标准管理办法&#xff08;试行&#xff09;》&#xff0c;全国团体标准《村镇污水处理一体化集成装备技术指南》&a…
阅读更多...
32.768k晶振FC-135R在智能手表手环中的作用

32.768k晶振FC-135R在智能手表手环中的作用

随着智能设备的普及&#xff0c;智能手表和手环已经成为人们日常生活中不可或缺的科技产品。晶振在智能手表手环中的作用是通过传感器给智能手环连接提供信号频率&#xff0c;是很重要的核心部位&#xff0c;这些设备的核心在于其精准的时钟管理和低功耗特性&#xff0c;32.768…
阅读更多...
Polar Web【中等】xxe

Polar Web【中等】xxe

Polar Web【中等】xxe Contents Polar Web【中等】xxe思路&探索EXP运行&总结 思路&探索 如题目所示&#xff0c;此题考查XXE漏洞&#xff0c;具体细节需要逐步深挖 打开站点&#xff0c;提示了flag所在的文件&#xff0c;点击按钮&#xff0c;可见php的配置信息&am…
阅读更多...
【CS.DB】深度解析：ClickHouse与Elasticsearch在大数据分析中的应用与优化

【CS.DB】深度解析：ClickHouse与Elasticsearch在大数据分析中的应用与优化

文章目录 《深入对比&#xff1a;在大数据分析中的 ClickHouse和Elasticsearch》 1 介绍 2 深入非关系型数据库的世界2.1 非关系型数据库的种类2.2 列存储数据库&#xff08;如ClickHouse&#xff09;2.3 搜索引擎&#xff08;如Elasticsearch&#xff09;2.4 核心优势的归纳 3…
阅读更多...
[word] word文字间隙怎么调整？ #媒体#职场发展

[word] word文字间隙怎么调整？ #媒体#职场发展

word文字间隙怎么调整&#xff1f; 在文档中的数据包含英文、数字、中文等&#xff0c;会有间隙&#xff0c;有时候误以为是空格&#xff0c;但是根本删除不了&#xff0c;其实这是默认的间隙&#xff0c;是可以调整的&#xff0c;下面教大家word文字间隙怎么调整的操作&#…
阅读更多...
【Modelground】个人AI产品MVP迭代平台（4）——Mediapipe视频处理网站介绍

【Modelground】个人AI产品MVP迭代平台（4）——Mediapipe视频处理网站介绍

文章目录 介绍模型配置输入输出核心实现&#xff08;源码&#xff09;总结 介绍 这篇文章我将硬核介绍Modelground的第一个产品——Mediapipe视频处理&#xff01;网站入口为https://tryiscool.space/ml-video/&#xff0c;如图所示&#xff0c;欢迎体验。 tip: 由于服务器带宽…
阅读更多...
以客户为中心：消费电子行业的产品研发之道

以客户为中心：消费电子行业的产品研发之道

在消费电子行业这片快速变化的领域中&#xff0c;产品的迭代更新和技术的创新是推动行业不断前进的动力。然而&#xff0c;随着市场的日益成熟和消费者需求的多样化&#xff0c;如何确保产品能够满足目标用户的需求&#xff0c;成为摆在每一个产品研发团队面前的难题。本文将探…
阅读更多...
理解JVM内存模型与Java内存模型（JMM）

理解JVM内存模型与Java内存模型（JMM）

理解JVM内存模型与Java内存模型&#xff08;JMM&#xff09; 在Java程序的运行过程中&#xff0c;内存管理和线程的同步是两个重要的概念。本文将深入探讨JVM内存模型&#xff08;Java Virtual Machine Memory Model&#xff09;和JMM&#xff08;Java Memory Model&#xff0…
阅读更多...
PyTorch学习5：Logistic回归

PyTorch学习5：Logistic回归

文章目录 前言一、分类问题简介二、示例1.示例步骤2.示例代码 总结 前言 介绍利用PyTorch实现Logistic回归的分类问题 一、分类问题简介 分类问题的输出为属于每一个类别的概率&#xff0c;概率值最大的即为所属类别。最常见的Sigmoid函数&#xff1a;Logistic函数。 二、示…
阅读更多...
了解Java内存模型（Java Memory Model, JMM）

了解Java内存模型（Java Memory Model, JMM）

了解Java内存模型&#xff08;Java Memory Model, JMM&#xff09; Java内存模型&#xff08;Java Memory Model, JMM&#xff09;是Java语言规范中规定的一组规则&#xff0c;定义了多线程程序中变量&#xff08;包括实例字段、静态字段和数组元素&#xff09;的访问方式。JM…
阅读更多...
树莓派4b安装宝塔面板

树莓派4b安装宝塔面板

1、打开命令窗口&#xff0c;执行如下命令 #更新 sudo apt-get update sudo apt-get upgrade #切换root权限 sudo su root #安装宝塔面板 wget -O install.sh http://download.bt.cn/install/install-ubuntu_6.0.sh && bash install.sh安装过程有点久&#xff0c;会持…
阅读更多...
备份树莓派系统的多种方法，构建镜像

备份树莓派系统的多种方法，构建镜像

在我们使用树莓派进行学习或者搭建实验环境时经常会把系统玩坏&#xff0c;辛苦配置的开发环境又得重新配置&#xff1b;或者更新某一软件后发现新版本和某些组件不兼容&#xff0c;又无法降级。这个时候我们会想将系统在稳定时进行备份&#xff0c;在系统出现问题后可以很方便…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023