备案控制台
探索云世界
开发者社区 开发与运维 文章 正文

Flutter 90: 图解 Dart 单线程实现异步处理之 Future (一)

2020-06-05 1249
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
简介： 0 基础学习 Flutter，简单学习 Future 实现异步的基本操作！

      小菜尝试过 Future 和 Stream 实现 Dart 异步处理，但仅限于基本的使用，网上有很多相关的资料，小菜仅从初识者的角度学习了解 Dart 的实现的异步处理；

      Dart 是单线程的！这点很重要，是不可变更的；但单线程的 Dart 是如何实现多线程的，这是很值得研究的；

      小菜了解的异步操作来处理耗时任务的方式主要是两种：一种是类似于 Java 的开启多线程，并在线程间通信；另一种是类似于 Dart 的单线程和事件循环 Event Loop；其中 Event Loop 事件循环就是把一系列的（点击事件/滑动事件/网络请求/ IO 事件等）事件存放在 Event Queue 队列中，循环执行从 Event Loop 中获取事件进行执行，直到清空队列事件；

      Dart 可以通过 Future 和 Stream 实现异步操作，小菜先尽量全面的学习 Future；

Future

Future Methods

      Future 的应用主要涉及三种状态，分别是未完成状态(UnCompleted / Pending)，完成成功(Completed with Data)，完成失败(Completed with Error)；

      当 Future 任务执行完成之后，通常需要一个回调，这个回调会立即执行，不会添加到事件队列中，其中通过 then() 的成功回调来来监听 Future 执行完成时获取到的结果；通过 catchError() 异常回调来监听 Future 执行失败或者出现异常时的错误信息；通过 whenComplete() 最终回调来获取最终回调，不管成功还是失败；

      小菜做了一个不太严谨的对比，这三种状态类似于 try-catch-finally，其中 try 对应 then() 成功回调，catch 对应 catchError() 异常回调，而 finally 对应 whenComplete() 最终回调；

      Future 还有两个常用的回调，分别是 timeout 超时回调和 asStream() 转换成 Stream 流回调；
Future 的使用可以通过 Future Constructors 构造方法或 async-await 方式；

Future.delayed(Duration(seconds: 3), () {
  print('Future.delayed(), CurrentTime = ${DateTime.now().millisecondsSinceEpoch}');
  return 'Future.delayed() result! CurrentTime = ${DateTime.now().millisecondsSinceEpoch}';
}).timeout(Duration(seconds: 1), onTimeout: () => 'Future.delayed() TimeOut! CurrentTime = ${DateTime.now().millisecondsSinceEpoch}')
    .then((val) => print(val))
    .whenComplete(() => print('Future.delayed() whenComplete! CurrentTime = ${DateTime.now().millisecondsSinceEpoch}'));

Future Constructors

1. Future(FutureOr computation())

      用于返回状态结果的基本构造方法；其中 computation 返回的可以是普通类型也可以是 Future；

factory Future(FutureOr<T> computation()) {
    _Future<T> result = new _Future<T>();
    Timer.run(() {
      try {
        result._complete(computation());
      } catch (e, s) {
        _completeWithErrorCallback(result, e, s);
      }
    });
    return result;
}

      分析源码可知，Future 主要是通过 Timer.run() 来执行，在回调方法中执行 computation();

Future(() => print('Future(FutureOr<T> computation()) 01'));
Future(() {
  print('Future(FutureOr<T> computation()) 02');
  return 'Future(FutureOr<T> computation()) 02 result!';
}).then((val) => print(val));
Future(() {
  print('Future(FutureOr<T> computation()) 03');
  return 'Future(FutureOr<T> computation()) 03 result!';
}).then((val) => print(val)).whenComplete(() => print('Future(FutureOr<T> computation()) 03 whenComplete!'));

2. Future.value([FutureOr value])

      创建一个固定类型的 Future；

Future.value('Future.value() 01').then((val) => print(val));
Future.value('Future.value() 02').then((val) => print(val));
Future.value('Future.value() 03')
    .then((val) => print(val))
    .whenComplete(() => print('Future.value() 03 whenComplete!'));

3. Future.delayed(Duration duration, [FutureOr computation()])

      delayed 是延迟执行，任务会到设置的延迟时间之后再执行；

factory Future.delayed(Duration duration, [FutureOr<T> computation()]) {
    _Future<T> result = new _Future<T>();
    new Timer(duration, () {
      if (computation == null) {
        result._complete(null);
      } else {
        try {
          result._complete(computation());
        } catch (e, s) {
          _completeWithErrorCallback(result, e, s);
        }
      }
    });
    return result;
}

      分析源码可知，与默认的构造方法相比，Timer 只是多了一个 duration，会在 duration 之后调用 computation()；

print('CurrentTime01 = ${DateTime.now().millisecondsSinceEpoch}');
Future.delayed(Duration(seconds: 3), () => print('Future.delayed() 01, CurrentTime = ${DateTime.now().millisecondsSinceEpoch}'));
print('CurrentTime02 = ${DateTime.now().millisecondsSinceEpoch}');
Future.delayed(Duration(seconds: 1), () => print('Future.delayed() 02, CurrentTime = ${DateTime.now().millisecondsSinceEpoch}'));
print('CurrentTime03 = ${DateTime.now().millisecondsSinceEpoch}');
Future.delayed(Duration(seconds: 2), () {
  print('Future.delayed() 03, CurrentTime = ${DateTime.now().millisecondsSinceEpoch}');
  return 'Future.delayed() 03 result! CurrentTime = ${DateTime.now().millisecondsSinceEpoch}';
}).then((val) => print(val)).whenComplete(() => print('Future.delayed() 03 whenComplete! CurrentTime = ${DateTime.now().millisecondsSinceEpoch}'));
print('CurrentTime04 = ${DateTime.now().millisecondsSinceEpoch}');

4. Future.sync(FutureOr computation())

      sync 是同步方法，任务会被立即执行；

factory Future.sync(FutureOr<T> computation()) {
    try {
      var result = computation();
      if (result is Future<T>) {
        return result;
      } else {
        return new _Future<T>.value(result);
      }
    } catch (error, stackTrace) {
      var future = new _Future<T>();
      AsyncError replacement = Zone.current.errorCallback(error, stackTrace);
      if (replacement != null) {
        future._asyncCompleteError(
            _nonNullError(replacement.error), replacement.stackTrace);
      } else {
        future._asyncCompleteError(error, stackTrace);
      }
      return future;
    }
}

      分析源码可知，与默认的构造方法相比，sync 直接调用 computation()，并未通过 Timer() 的回调；

Future.sync(() => print('Future.sync() 01'));
Future.sync(() {
  print('Future.sync() 02');
  return 'Future.sync() 02 result!';
}).then((val) => print(val));
Future.sync(() {
  print('Future.sync() 03');
  return 'Future.sync() 03 result!';
}).then((val) => print(val)).whenComplete(() => print('Future.value() 03 whenComplete!'));

5. Future.error(Object error, [StackTrace stackTrace])

      error 主要创建一个异常状态的 Future；

Future.error(ArgumentError.notNull('Input'));
Future.error('Future error01')
    .then((val) => print('Future.error01 result = $val'))
    .catchError((val) => print(val));
Future.error('Future error02')
    .then((val) => print('Future.error02 result = $val'))
    .catchError((val) => print(val))
    .whenComplete(() => print('Future.error03 whenComplete!'));

6. Future.microtask(FutureOr computation())

      microtask 比较特殊，会创建一个微队列事件的 Future，Dart 的异步任务队列主要包括 Event Queue 普通事件队列和 Microtask Queue 微事件队列，其中 Microtask Queue 的执行优先级更高，Future 默认是 Event Queue 普通队列事件，小菜会在后面的博客中进一步研究；

Future.microtask(() => print('Future.microtask() 01'));
Future.microtask(() {
  print('Future.microtask() 02');
  return 'Future.microtask() 02 result!';
}).then((val) => print(val)).whenComplete(() => print('Future.microtask() 02 whenComplete!'));
Future.microtask(() => print('Future.microtask() 03'));

Future Static Methods

1. any(Iterable> futures)

      静态方法 any() 是 Futures 数组中完成第一个 Future 的回调监听，包括成功回调 then() 和异常回调 catchError()，其中第一个 Future 完成之后，并不影响其他的 Future 执行；

Future.any([
  Future.delayed(Duration(seconds: 4)).then((val) => 4),
  Future.delayed(Duration(seconds: 2)).then((val) => '2'),
  Future.delayed(Duration(seconds: 3)).then((val) => null),
]).then((val) => print(val));

Future.any([
  Future.error(ArgumentError.notNull('Input')),
  Future.error('Future error01').then((val) => print('Future.error01 result = $val')).catchError((val) => print(val)),
  Future.error('Future error02').then((val) => print('Future.error02 result = $val')).catchError((val) => print(val))
      .whenComplete(() => print('Future.error03 whenComplete!'))
]).then((val) => print('Future.any() --> then()'))
    .catchError((val) => print('Future.any() --> catchError() --> $val'))
    .whenComplete(() => print('Future.any() whenComplete!'));

2. doWhile(FutureOr action())

      静态方法 doWhile() 可以用来执行循环任务，只有当返回内容是 false 或异常时停止；

var i = 0;
Future.doWhile(() {
  ++i;
  return Future.delayed(Duration(seconds: 2), () {
    print('Future.doWhile() $i, CurrentTime = ${DateTime.now().millisecondsSinceEpoch}');
    return i < 6;
  }).then((val) {
    print(val);
    return val;
  });
}.then((val) => print('Future.doWhile -> then() -> $val'))
    .whenComplete(() => print('Future.doWhile -> whenComplete()'));

3. forEach(Iterable elements, FutureOr action(T element))

      静态方法 forEach() 用来遍历执行 elements 中各 item，不止于单一数据类型；

Future.forEach([
  1,
  Future(() => print('Future.forEach() 01')),
  Future(() {
    print('Future.forEach() 02');
    return 'Future.forEach() 02 result!';
  }).then((val) => print(val)),
  'Hello Flutter!',
  Future(() {
    print('Future.forEach() 03');
    return 'Future.forEach() 03 result!';
  }).then((val) => print(val))
      .whenComplete(() => print('Future.forEach() 03 whenComplete!'))
], (val) => print(val))
    .then((val) => print('Future.forEach() -> then() -> $val'))
    .whenComplete(() => print('Future.forEach() -> whenComplete()'));

4. wait(Iterable> futures, {bool eagerError: false, void cleanUp(T successValue)})

      静态方法 wait() 用来等待多个 Futures 完成之后再执行，并收集结果，其中 Futures 时按延迟或其他顺序执行，只有所有的 Futures 结束之后会按 Futures 数组收集；

Future.wait([
  Future.delayed(Duration(seconds: 4)).then((val) {
    print('Future -> 4');
    return 4;
  }).whenComplete(() => print('Future -> 4 whenComplete!')),
  Future.delayed(Duration(seconds: 2)).then((val) {
    print('Future -> 2.toString()');
    return '2';
  }).whenComplete(() => print('Future -> 2.toString() whenComplete!')),
  Future.delayed(Duration(seconds: 3)).then((val) {
    print('Future -> null');
    return null;
  }).whenComplete(() => print('Future -> null whenComplete!')),
]).then((val) => print(val))
    .catchError((val) => print('Future.wait() --> catchError() --> $val'))
    .whenComplete(() => print('Future.wait() whenComplete!'));

      a. Future.wait() 只会捕获 Futures 中第一个异常，且当前 Future 未进行捕获，即：Future 中都进行了 catchError 则不会进入 wait().catchError()；

Future.wait([
  Future.delayed(Duration(seconds: 4)).then((val) {
    print('Future -> 4');
    return 4;
  }).whenComplete(() => print('Future -> 4 whenComplete!')),
  Future.error('Future error01')
      .then((val) => print('Future.error01 result = $val'))
      .catchError((val) => print(val)),
  Future.error(ArgumentError.notNull('Input')),
  Future.error('Future error02')
      .then((val) => print('Future.error02 result = $val'))
      .catchError((val) => print(val))
      .whenComplete(() => print('Future.error02 whenComplete!'))
]).then((val) => print('Future.wait() --> then()'))
    .catchError((val) => print('Future.wait() --> catchError() --> $val'))
    .whenComplete(() => print('Future.wait() whenComplete!'));

      b. wait() 但异常捕获时机与 eagerError 参数相关，eagerError = true 时，Futures 中第一个返回异常时 wait() 立即捕获；eagerError = false 时，需等 Futures 全部执行结束之后才会捕获；

eagerError: true

      c. Futures 中出现异常时，cleanUp 会给每项正常执行的 Future 进行清理操作，传递给 cleanUp 的参数为每个正常执行项的返回内容；

Future.wait([
  Future.delayed(Duration(seconds: 4)).then((val) {
    print('Future -> 4');
    return 4;
  }).whenComplete(() => print('Future -> 4 whenComplete!')),
  Future.error('Future error01')
      .then((val) => print('Future.error01 result = $val'))
      .catchError((val) => print(val)),
  Future.error(ArgumentError.notNull('Input')),
  Future.delayed(Duration(seconds: 2)).then((val) {
    print('Future -> 2.toString()');
    return '2';
  }),
  Future.error('Future error02')
      .then((val) => print('Future.error02 result = $val'))
      .catchError((val) => print(val))
      .whenComplete(() => print('Future.error02 whenComplete!')),
], cleanUp: (val) => print('Future.wait() --> cleanUp --> $val'))
    .then((val) => print('Future.wait() --> then()'))
    .catchError(
        (val) => print('Future.wait() --> catchError() --> $val'))
    .whenComplete(() => print('Future.wait() whenComplete!'));

      Dart Future 案例尝试

      小菜对 Dart 异步的认知还不完全，接下来会继续尝试 await-async 以及 EventLoop 执行顺序等；如有错误和遗漏请多多指导！

来源： 阿策小和尚

文章标签：
Java
Dart
关键词：
线程future
Flutter Dart
Flutter单线程
Flutter实现
Flutter future
阿策～
目录
相关文章
陌陌谣
|
3月前
|
监控 Dart 安全
创建一个Dart应用，监控局域网上网记录的软件：Flutter框架的应用
在当今数字时代，网络安全变得愈发重要。为了监控局域网上的上网记录，我们可以借助Flutter框架创建一个强大的Dart应用。在这篇文章中，我们将深入讨论如何使用Flutter框架开发这样一个监控局域网上网记录的软件，并提供一些实用的代码示例。
陌陌谣
274 1
还在路上的秃头
|
1月前
|
Java
多线程------Future异步任务
多线程------Future异步任务
还在路上的秃头
22 1
NewBoy
|
2月前
|
Dart JavaScript
Flutter - Dart 基础（数据类型）
【2月更文挑战第3天】
NewBoy
64 1
NewBoy
|
2月前
|
Dart JavaScript 安全
Flutter - Dart 基础（关于 var、null、late、const、final 等等）
【2月更文挑战第2天】
NewBoy
58 1
Flutter - Dart 基础（关于 var、null、late、const、final 等等）
左边的天堂
|
2月前
|
Dart Shell 开发工具
解决windows安装Flutter时出现Unknown operating system. Cannot install Dart SDK.问题
解决windows安装Flutter时出现Unknown operating system. Cannot install Dart SDK.问题
左边的天堂
51 0
jcLee95
|
3月前
|
JSON Dart 算法
Dart/Flutter工具模块：the_utils
Dart/Flutter工具模块：the_utils
jcLee95
47 0
jcLee95
|
3月前
|
Dart 小程序 前端开发
WebSocket 解析与应用（包含web前端、服务端、小程序、dart/flutter中的用法）
WebSocket 解析与应用（包含web前端、服务端、小程序、dart/flutter中的用法）
jcLee95
195 0
童小纯
|
3月前
|
设计模式 安全 Java
多线程设计模式【线程安全、 Future 设计模式、Master-Worker 设计模式 】(一)-全面详解（学习总结---从入门到深化）
多线程设计模式【线程安全、 Future 设计模式、Master-Worker 设计模式 】(一)-全面详解（学习总结---从入门到深化）
童小纯
28 0
Web3-Basketball
|
8月前
|
开发框架 Dart Java
Flutter中Dart语言常用知识
@[TOC](目录) Flutter 是一种使用 Dart 语言开发的跨平台移动应用程序框架。在 Flutter 中，Dart 语言是主要的编程语言，它提供了许多强大的功能和语法糖，可以让开发者更轻松地构建高性能、美观的应用程序。下面是 Flutter 中 Dart 语言的一些详细介绍和代码示例： # 1. 变量和数据类型 在 Dart 语言中，变量不需要声明，可以直接赋值。Dart 语言支持多种数据类型，包括整数、浮点数、布尔值、字符串、列表、映射等。例如： ```dart int a = 10; double b = 3.14; bool c = true; String
Web3-Basketball
79 0
代码迷途
|
Dart 索引
[Flutter]足够入门的Dart语言系列之变量的类型：bool、String、num、List、Set和Map
变量的类型指的是变量的特性或特征，比如表示数字类型、文本类型、集合类型等，表示的是一类数据。 Dart提供以下类型：int, double、String、List、Set、Map、null...
代码迷途
552 0
[Flutter]足够入门的Dart语言系列之变量的类型：bool、String、num、List、Set和Map

热门文章

最新文章

  • 1
    Doodle Jump — 使用Flutter&Flame开发游戏真不错！
  • 2
    使用Riverpod在Flutter中创建Todo列表
  • 3
    flutter-barrage-craft — 能成为pub.dev中最好用的弹幕插件吗🤔？
  • 4
    移动端 Hybrid 开发：RN、Flutter与Webview的抉择与融合
  • 5
    对象存储oss使用问题之flutter使用http库进行post请求文件上传返回400如何解决
  • 6
    Java中的多线程编程：概念、实现与性能优化
  • 7
    【Qt 底层之事件驱动系统】深入理解 Qt 事件机制：主事件循环与工作线程的交互探究，包括 QML 的视角
  • 8
    Python 学习之路 01基础入门---【Python安装，Python程序基本组成】
  • 9
    【C/C++ 线程池设计思路】 深入探索线程池设计：任务历史记录的高效管理策略
  • 10
    【C++ const 函数 的使用】C++ 中 const 成员函数与线程安全性：原理、案例与最佳实践
  • 1
    写一个线程来监控各线程是否发生阻塞
    8
  • 2
    Java线程：深入理解与实战应用
    13
  • 3
    Java中的并发编程：理解和应用线程池
    8
  • 4
    Linux(29) 多线程快速解压缩|删除|监视大型文件
    10
  • 5
    并发编程之线程池的底层原理的详细解析
    11
  • 6
    并发编程之线程池的详细解析
    6
  • 7
    并发编程之线程池的应用以及一些小细节的详细解析
    16
  • 8
    使用代理IP池实现多线程的方法
    6
  • 9
    深入理解 Java 多线程和并发工具类
    14
  • 10
    java多线程（一）(火车售票)
    24

    • 相关电子书

    更多
  • 基于flutter的产品应用实践
  • 《Flutter in action》
  • 闲鱼《Flutter 技术解析与实战》
    • 下一篇
    部署LAMP环境（Alibaba Cloud Linux 3）