Flutter开发指南之理论篇:Dart语法05(单线程模型,事件循环模型,Isolate)

Stella981 等级 259 0 0

此文转载自:https://blog.csdn.net/AndrExpert/article/details/110823218

总目录

Flutter开发指南之理论篇:Dart语法01(数据类型,变量,函数)
Flutter开发指南之理论篇:Dart语法02(运算符,循环,异常)
Flutter开发指南之理论篇:Dart语法03(类,泛型)
Flutter开发指南之理论篇:Dart语法04(库,异步,正则表达式)
Flutter开发指南之理论篇:Dart语法05(单线程模型,事件循环模型,Isolate)
Flutter开发指南之理论篇:Flutter基础01(架构,设计思想)


 Dart是一门面向对象语言,它针对web 和移动设备开发进行了优化,主要特点为:

  • 一切皆对象!无论是数字,函数还是null,所有对象继承自Object类;
  • 声明一个变量时可以不指定具体类型,Dart可以自动推断类型;
  • Dart支持顶层函数,函数是一等对象,且函数可作为参数传递;
  • Dart使用_开头表示私有属性,没有关键字publicprotectedprivate

1. 单线程模型

众所周知,在Java中使用多线程来处理并发任务,适量并合适地使用多线程,能够极大地提高资源的利用率和程序运行效率,但是缺点也比较明显,比如过度开启线程会带来额外的资源和性能消耗多线程共享内存容易出现死锁等。实际上,在APP的使用过程中,多数处理空闲状态,并不需要进行密集或高并发的处理,因此从某些意义上来说,多线程显得有点多余。正是因为如此,Dart作为一种新的语言,通过引单线程模型很好地处理了并发任务对多线程的依赖。

1.1 单线程模型

Dart是一种单线程语言,因此Dart程序没有主线程和子线程之分,而在Dart中线程并不是指Thread,而是指Isolate。因为Dart没有线程的概念,只有Isolate,每个Isolate都是隔离的,并不会共享内存。所有的Dart代码都是在Isolate中运行,它就像机器上的一个小空间,具有自己的私有内存块和一个运行着事件循环模型的单线程。也就是说,一旦某个Dart函数开始执行,它将执行到这个函数的结束而不被其他Dart代码打断,这就是单线程的特性。

Flutter开发指南之理论篇:Dart语法05(单线程模型,事件循环模型,Isolate)

 默认情况下,Dart程序只有一个Isolate(未自己创建的情况下),而这个Isolate就是Main Isolate。也就是说,一个Dart程序是从Main Isolate的main函数开始的,而在main函数结束后,Main isolate线程开始一个一个处理事件循环模型队列中的每一事件(Event)。上图描述的就是Main Isolate的消息循环模型。

1.2 事件循环模型

也许你会问,既然Dart是一种单线程语言,那么是不是就意味着Dart无法并发处理异步任务了?此言差矣。前面说到,所有的Dart程序都在Isolate中运行,每个Isolate拥有自己的私有内存块和一个事件循环模型,其中,事件循环模型就是用来处理各种事件,比如点输入/输出,点击,定时器以及异步任务等。下图描述了一个Isolate事件循环模型的整个流程:

Flutter开发指南之理论篇:Dart语法05(单线程模型,事件循环模型,Isolate)

 从上图可知,Dart事件循环机制由一个消息循环(event looper)两个消息队列构成,其中,两个消息队列是指事件队列(event queue)微任务队列(Microtask queue)。该机制运行原理为:

  • 首先,Dart程序从main函数开始运行,待main函数执行完毕后,event looper开始工作;
  • 然后,event looper优先遍历执行Microtask队列所有事件,直到Microtask队列为空;
  • 接着,event looper才遍历执行Event队列中的所有事件,直到Event队列为空;
  • 最后,视情况退出循环。

 为了进一步理解,我们解释下上述三个概念:

(1)消息循环(Event Looper)

 顾名思义,消息循环就是指一个永不停歇且不能阻塞的循环,它将不停的尝试从微任务队列事件队列中获取事件(event)进行处理,而这些Event包括了用户输入,点击,Timer,文件IO等。

Flutter开发指南之理论篇:Dart语法05(单线程模型,事件循环模型,Isolate)

(2)事件队列(Event queue)

 该队列的事件来源于外部事件Future,其中,外部事件主要包括I/O,手势,绘制,计时器和isolate相互通信的message等,而Future主要是指用户自定义的异步任务,通过创建Future类实例来向事件队列添加事件。需要注意的是,当Event looper正在处理Microtask Queue时,Event queue会被阻塞,此时APP将无法进行UI绘制,响应用户输入和I/O等事件。下列示例演示了向Event queue中添加一个异步任务事件:

main(List<String> args) {
  print('main start...')
  
  var futureInstance = Future<String>(() => "12345");
  futureInstance.then((res) {
    print(res);
  }).catchError((err) {
    print(err);
  });
  
  print('main end...')
}

// 打印结果:
//      main start...
//      main end...
//      12345

(3)微任务队列(Microtask queue)

该队列的事件来源与当前isolate的内部或通过scheduleMicrotask函数创建,Microtask一般用于非常短的内部异步动作,并且任务量非常少,如果微任务非常多,就会造成Event queue排不上队,会阻塞Event queue的执行造成应用ANR,因为Microtask queue的优先级高于Event queue。因此,大多数情况下的任务优先考虑使用Event queue,不到万不得已不要使用Microtask queue。下列示例演示了两个事件队列执行情况:

import 'dart:async';
main() {
  print('main #1 of 2');
  scheduleMicrotask(() => print('microtask #1 of 2'));

  new Future.delayed(new Duration(seconds:1),
                     () => print('future #1 (delayed)'));
  new Future(() => print('future #2 of 3'));
  new Future(() => print('future #3 of 3'));

  scheduleMicrotask(() => print('microtask #2 of 2'));

  print('main #2 of 2');
}

// 执行结果:
//      main #1 of 2
//      main #2 of 2
//      microtask #1 of 2
//      microtask #2 of 2
//      future #2 of 3
//      future #3 of 3
//      future #1 (delayed)

2. Isolate

大多数计算机中,甚至在移动平台上,都在使用多核CPU。 为了有效利用多核性能,开发者一般使用共享内存数据来保证多线程的正确执行。 然而多线程共享数据通常会导致很多潜在的问题,并导致代码运行出错。Dart作为一种新语言,为了缓解上述问题,提出了Isolate(隔离区)的概念,即Dart没有线程的概念,只有Isolate,所有的Dart代码都是在Isolate中运行,它就像是机器上的一个小空间,具有自己的私有内存堆和一个运行着Event Looper的单个线程。

Flutter开发指南之理论篇:Dart语法05(单线程模型,事件循环模型,Isolate)

 通常,一个Dart应用对应着一个Main Isolate,且应用的入口即为该Isolate的main函数。当然,我们也可以创建其它的Isolate,由于Isolate的内存堆是私有的,因此这些Isolate的内存都不会被其它Isolate访问。假如不同的Isolate需要通信(单向/双向),就只能通过向对方的事件循环队列里写入任务,并且它们之间的通讯方式是通过port(端口)实现的,其中,Port又分为receivePort(接收端口)sendPort(发送端口),它们是成对出现的。Isolate之间通信过程:

  • 首先,当前Isolate创建一个ReceivePort对象,并获得对应的SendPort对象;

    var receivePort = ReceivePort(); var sendPort = receivePort.sendPort;

  • 其次,创建一个新的Isolate,并实现新Isolate要执行的异步任务,同时,将当前Isolate的SendPort对象传递给新的Isolate,以便新Isolate使用这个SendPort对象向原来的Isolate发送事件;

    // 调用Isolate.spawn创建一个新的Isolate // 这是一个异步操作,因此使用await等待执行完毕 var anotherIsolate = await Isolate.spawn(otherIsolateInit, receivePort.sendPort);

    // 新Isolate要执行的异步任务 // 即调用当前Isolate的sendPort向其receivePort发送消息 void otherIsolateInit(SendPort sendPort) async { value = "Other Thread!"; sendPort.send("BB"); }

  • 第三,调用当前Isolate#receivePort的listen方法监听新的Isolate传递过来的数据。Isolate之间什么数据类型都可以传递,不必做任何标记。

    receivePort.listen((date) { print("Isolate 1 接受消息:data = $date"); });

  • 最后,消息传递完毕,关闭新创建的Isolate。

    anotherIsolate?.kill(priority: Isolate.immediate); anotherIsolate =null;

示例代码如下(Isolate单向通信):

import 'dart:isolate';

var anotherIsolate;
var value = "Now Thread!";

void startOtherIsolate() async {
  var receivePort = ReceivePort();

  anotherIsolate = await Isolate.spawn(otherIsolateInit, receivePort.sendPort);

  receivePort.listen((date) {
    print("Isolate 1 接受消息:data = $date,value = $value");
  });
}

void otherIsolateInit(SendPort sendPort) async {
  value = "Other Thread!";
  sendPort.send("BB");
}

// 在Main Isolate创建一个新的Isolate
// 并使用Main Isolate的ReceiverPort接收新Isolate传递过来的数据
import 'DartLib.dart';

void main(){
  startOtherIsolate();
}

 执行结果:

Isolate 1 接受消息:data = BB,value = Now Thread! 

3. 参考文献

1. Dart asynchronous programming: Isolates and event loops
2. Futures - Isolates - Event Loop
3. Flutter 真异步

本文同步分享在 博客“phyger”(CNBlog)。
如有侵权,请联系 support@oschina.cn 删除。
本文参与“OSC源创计划”,欢迎正在阅读的你也加入,一起分享。

收藏
评论区

相关推荐

Dart官方文档翻译(一)(Dart之旅)
这篇文章将会向你展示如何使用Dart的每一个知识点,包括变量,操作符,类,类库,但这是在你已经有一个其他语言的编码经验的前提下。 为了学习Dart更多关于Dart的核心类库,请查看A Tour of the Dart Libraries,当你想知道更多语言特征,挺查阅Dart language specification 你可以通过DartPad 来尝试
flutter -- dart基础之dart简介和安装
Dart介绍: Dart是由谷歌开发的计算机编程语言,它可以被用于web、服务器、移动应用 和物联网等领域的开发。 Dart诞生于2011年,号称要取代JavaScript。但是过去的几年中一直不温不火。直到Flutter的出现现在被人们重新重视。 要学Flutter的话我们必须首先得会Dart。 da
Dart | 浅析dart中库的导入与拆分
前言 最近十分热门的跨平台框架使用了一门比较生僻的编程语言dart。dart语言本身深受早期一些编程语言的影响。特别是Smalltalk,Java和JavaScript。我是从Java语言向dart过度的,一开始感觉很不错,快速就对这门语言有了一个初步的认识,并能够写小段代码了。 但在flutter的不断学习过程中,我遇到了不少因为dart的一些语
【Flutter实战】调试Flutter应用
2.5 调试Flutter应用有各种各样的工具和功能来帮助调试Flutter应用程序。 Dart 分析器在运行应用程序前,请运行flutter analyze测试你的代码。这个工具是一个静态代码检查工具,它是dartanalyzer工具的一个包装,主要用于分析代码并帮助开发者发现可能的错误,比如,Dart分析器大量使用了代码中的类型注释来帮
【Flutter实战】调试Flutter应用
2.5 调试Flutter应用有各种各样的工具和功能来帮助调试Flutter应用程序。 Dart 分析器在运行应用程序前,请运行flutter analyze测试你的代码。这个工具是一个静态代码检查工具,它是dartanalyzer工具的一个包装,主要用于分析代码并帮助开发者发现可能的错误,比如,Dart分析器大量使用了代码中的类型注释来帮
【Flutter实战】Dart线程模型及异常捕获
2.6 Flutter异常捕获在介绍Flutter异常捕获之前必须先了解一下Dart单线程模型,只有了解了Dart的代码执行流程,我们才能知道该在什么地方去捕获异常。 2.6.1 Dart单线程模型在Java和ObjectiveC(以下简称“OC”)中,如果程序发生异常且没有被捕获,那么程序将会终止,但是这在Dart或JavaScript中则不会!
Flutter - 深入理解Flutter应用启动
基于Flutter 1.5,从源码视角来深入剖析flutter应用的启动流程,相关源码目录见文末附录一、概述上一篇文章 已经介绍了FlutterApplication和FlutterActivity的onCreate()方法执行过程, 并触发Flutter引擎的启动,并最终执行到runApp(Widget app)方法,这才刚刚开始执行dart的
Flutter - 深入理解Dart虚拟机启动
基于Flutter 1.5,从源码视角来深入剖析引擎启动中的Dart虚拟机启动流程,相关源码目录见文末附录一、概述 1.1 Dart虚拟机概述Dart虚拟机拥有自己的Isolate,完全由虚拟机自己管理的,Flutter引擎也无法直接访问。Dart的UI相关操作,是由Root Isolate通过Dart的C调用,或者是发送消息通知的方式
Dart虚拟机运行原理
一、Dart虚拟机 1.1 引言Dart VM是一种虚拟机,为高级编程语言Dart提供执行环境,但这并意味着Dart在D虚拟机上执行时,总是采用解释执行或者JIT编译。 例如还可以使用Dart虚拟机的AOT管道将Dart代码编译为机器代码,然后运行在Dart虚拟机的精简版环境,称之为预编译运行时(precompiled runtime)环境,该环境不包含任何
Flutter Android 端集成 JPush 推送
前提 == > `Flutter` 版本:`1.17.0`,别用最新版本或者比较老的版本。我之前使用`1.13.0`版本也会出现问题。 > `Dart`版本:`2.8.1`使用`Flutter`中提供的版本 ![在这里插入图片描述](https://oscimg.oschina.net/oscnet/up-5a7976e2ca8c3b3bfb8080
Flutter Weekly Issue 55
### 新闻 1. [Flutter 1.17 | 2020 首个稳定版发布!](https://www.oschina.net/action/GoToLink?url=https%3A%2F%2Fmp.weixin.qq.com%2Fs%2FVXNbqxpoVDJeOPkBt5_88A) 2. [Dart 2.8 发布了](https://
Flutter 不一样的跨平台解决方案
> 本文主要介绍Flutter相关的东西,包括Fuchsia、Dart、Flutter特性、安装以及整体架构等内容。 1\. 简介 ------ Flutter作为谷歌最近推出的跨平台开发框架,一经推出便吸引了不少注意。关于Flutter,目前我们知道它是一个跨平台开发框架。但是它本身并不止于此,例如Fuchsia、Dart等,我们也都需要去了解。 #
Flutter 介绍、运行环境
Flutter 是谷歌公司开发的一款开源、免费的移动 UI 框架,可以让我们快速的在 Android 和iOS 上构建高质量 App。它最大的特点就是跨平台、以及高性能。 Flutter 基于谷歌的 dart 语言,如果没有任何 Dart 语言的基础,不建议直接学习 Flutter。建议先学习 Dart 语言的基本语法。然后再进入 Flutter 的学习
Flutter开发常用第三方插件汇总
Bilibili开源的视频播放组件,fijkplayr 是基于 ijkplayer 封装的 flutter 媒体播放器,开箱即用,无需编译 ijkplayer \[fijkplayer\](https://github.com/befovy/fijkplayer) 加载动画库 \[flutter\_spinkit\](https://githu
Flutter开发指南之理论篇:Dart语法05(单线程模型,事件循环模型,Isolate)
此文转载自:https://blog.csdn.net/AndrExpert/article/details/110823218 总目录 === [Flutter开发指南之理论篇:Dart语法01(数据类型,变量,函数)](https://www.oschina.net/action/GoToLink?url=https%3A%2F%2Fjiangd