Dart是基于 事件循环机制 的 单线程模型
一条执行线上,同时且只能执行一个任务(事件),其他任务都必须在后面排队等待被执行。也就是说,在一条执行线上,为了不阻碍代码的执行,每遇到的耗时任务都会被挂起放入任务队列,待执行结束后再按放入顺序依次执行队列上的任务,从而达到异步效果。
单线程模型按照代码编写的顺序,自上而下运行,这是我们所认知的,但是当遇到耗时操作(IO/网络请求)等,会给UI造成卡顿阻塞,那么在Flutter中是怎么解决这个问题的呢?接下来我们来仔细分析:
Dart是基于单线程模型的语言。在Dart中也有自己的进程机制 – isolate 。APP的启动入口main函数就是一个 ioslate ,Dart中的ioslate之间无法直接共享内存,不同ioslate之间只能通过ioslate api进行通信。
在Dart中实现并发可以用Isolate,它是类似于线程(thread)但不共享内存的独立运行的worker,是一个独立的Dart程序执行环境。其实默认环境就是一个main isolate。
在Dart语言中,所有的Dart代码都运行在某个isolate中,代码只能使用所属isolate的类和值。不同的isolate可以通过port发送message进行交流。(首字母大写的Isolate代表Isolate对象,小写的isolate代表一个独立的Dart代码执行环境)
一个Isolate对象就是一个isolate(执行环境)的引用,通常不是当前代码所在的isolate,也就是说,当你使用Isolate对象时,你的目的应该是控制其他isolate,而不是当前的isolate。
import 'dart:isolate';
void main() {
ReceivePort port = ReceivePort();
Isolate.spawn(fun, port.sendPort);///固定写法
port.listen((t) {///这里是设置当前receivePort 监听
print("接收到其他isolate发过来的消息!");///这里接收了其他isolate发送的消息
print(t);///接收到的为fun方法里面发送的消息
});
}
void fun(SendPort sendPort) {
var receivePort = new ReceivePort();
var port = receivePort.sendPort;
port.send("a");///发送消息
sendPort.send("---");///发送消息
receivePort.listen((t) {///这里是设置当前receivePort 监听
print("接收到当前isolate发过来的消息!");///这里接收了当前发送的消息
print(t);
});
}
Dart线程中有一个消息循环机制(event looper)和两个队列(event queue事件队列和microtask queue微服务队列)
event queue 事件队列 包含所有外来的事件:IO操作,按钮点击,绘图等消息。任意ioslate中新增的event都会放入消息队列中排队等待
microtask queue 微任务队列 值在当前ioslate的任务队列中排队,优先级高于event queue
Dart代码的运行是从main函数开始的,main函数执行完毕后,Event Looper开始工作,MQ微服务队列优先级高于EQ事件队列,所以Event Looper优先执行MQ中的event事件,当全部执行完毕后,再去执行EQ事件队列中的event。
MQ 微服务队列的优先级要高于EQ事件队列,Event Looper优先执行MQ队列中的事件,其次执行EQ事件队列中的事件
MQ 微服务队列中一般来自于Dart内部,并且微任务非常少。因为如果微任务很多的话,就会造成事件队列排不上对,会阻塞任务队列的执行
可以通过async下的schedlueMicrotask来创建一个微任务:
import "dart:async";
main(List<String> args) {
scheduleMicrotask(() {
print("我是一个微任务");
});
}
事件队列一般来自于外部事件任务,例如IO操作、计时器、点击、绘图等等
上面说过 如果微任务很多的话就有可能造成事件队列中的事件排不上对,可能会造成点击一个按钮没有反应造成阻塞,所以微服务不宜过多
另外一部分来源于Future(自定义EQ事件)
它们是Dart中的关键字,可以让我们用同步的代码格式来做异步的任务
async 描述一个执行异步操作的方法
await 表示一直等待异步方法返回结果,才继续往后执行
一般一个async的函数会返回一个Future
//HTTP的get请求返回值为Future<String>类型,即其返回值未来是一个String类型的值
getData() async { //async关键字声明该函数内部有代码需要延迟执行
return await http.get(Uri.encodeFull(url), headers: {"Accept": "application/json"}); //await关键字声明运算为延迟执行,然后return运算结果
}
:warning:注意:这里retrun的并不是我们想要的数据结构类型,他的返回类型时一个await延迟执行的结果。在Dart中,有await标记的运算,其返回结构都是一个Future对象,所以我们可以这样写:
String data;
getData() async {
data = await http.get(Uri.encodeFull(url), headers: {"Accept": "application/json"}); //延迟执行后赋值给data
}
:warning::
await关键字必须在async函数内部使用
调用async函数必须使用await关键字
Future对象表示异步操作的结果,进程或者IO会延迟完成;我们可以通过它在某个时间点获得异步任务中返回的值,每一个Future都是一个Event,例如我们常用的RefreshIndicator下拉刷新组件中的onRefresh()方法就是一个event,每一个被await标记的句柄也是一个event,没创建一个Future都会把这个Future放进EQ队列中进行排队。
then() 函数 任务执行完成后会进入then函数,能够获取返回的结果
**catchError()**函数 任务失败时,可以在此捕获异常
**whenComplete()**函数 任务结束完成后,进入这里
**wait()**函数 等待多个异步任务执行完成后,再调用then()
**delayed()**函数 延迟任务执行
:warning::
Future没有执行完成(有任务需要执行),那么then会直接被添加到Future的函数执行体后;
如果Future执行完后就then,该then的函数体被放到如微任务队列,当前Future执行完后执行微任务队列
如果Future世链式调用,意味着then未执行完,下一个then不会执行
// future_1加入到eventqueue中,紧随其后then_1被加入到eventqueue中
Future(() => print("future_1")).then((_) => print("then_1"));
// Future没有函数执行体,then_2被加入到microtaskqueue中
Future(() => null).then((_) => print("then_2"));
// future_3、then_3_a、then_3_b依次加入到eventqueue中
Future(() => print("future_3")).then((_) => print("then_3_a")).then((_) => print("then_3_b"));
Future<bool> createFile(String path) async {
final tempDic = new Directory(path);
var exits = await tempDic.exists();
if (exits) {
return Future(() => false);
}
tempDic.createSync(recursive: true);
return Future(() => true);
}
Stream和 Future 一样都是Dart中用来做异步操作的,官方对其定义为:
Widgets + Stream = reactive Flutter APP
Stream的作用类似于Android开发中RxJava或者LiveData。它是一个异步流,我们可以在代码中任何地方定义 Stream,然后在其他地方添加数据, Stream 会监听到数据变化,并将改变后的数据传递给监听者。
单订阅流(Single Subscription)
多订阅流(BroadCast)
创建一个Stream返回Future:
Stream<String>.fromFuture(xxxx)
创建一个Stream返回集合对象:
Stream<String>.fromIterable(['x','x','x'])
创建一个Stream返回Futures集合对象:
Stream<String>.fromFutures([xxx]);
创建一个Stream返回Duration对象:
Duration interval = Duration(seconds: 1);
Stream<int> stream = Stream<int>.periodic(interval);
详细可见:https://segmentfault.com/a/1190000019974515
里面有详细的操作符介绍
StreamController类似一个管道,在这个管道中封装了Stream,并向我们提供了两个接口来操作Stream:
sink 从Stream中的一端插入数据
stream 从Stream的另一端弹出数据
具体使用:
创建StreamController
StreamController<String> controller = new StreamController<String>();
向Stream中添加数据
controller.sink.add("Item1");
controller.sink.add("Item2");
controller.sink.add("Item3");
创建Stream监听器
通过StreamController中的stream.listen(),设置监听Stream弹出的数据:
controller.stream.listen((item) => print(item));
// 向Stream中添加error
controller.sink.addError('there is a problem!');
controller.sink.close(); // 调用close方法,结束Stream中的逻辑处理
以上部分是单订阅流,也就是单监听器的Stream,下面来看下多订阅流的使用:
构建多订阅流的方式有两种
直接创建多订阅Stream
StreamController<String> streamController = StreamController.broadcast();
streamController.stream.listen((data){
print(data);
},onError: (error){
print(error.toString());
});
streamController.stream.listen((data) => print(data));
streamController.add("bbb");
将单订阅流转成多订阅流
StreamController<String> streamController = StreamController();
Stream stream =streamController.stream.asBroadcastStream();
stream.listen((data) => print(data));
stream.listen((data) => print(data));
streamController.sink.add("aaa");
streamController.close();
StreamBuilder是Flutter中的一个Widget,记录着流中最新的数据,当数据流发生变化时,会自动调用Builder进行重建
const StreamBuilder({
Key key,
this.initialData,
Stream<T> stream,
@required this.builder,
}) : assert(builder != null),
super(key: key, stream: stream);
可以看到StreamBuilder需要接受一个Stream
使用 StreamController 结合 StreamBuider 对官方的计数器进行改进,取代setState刷新页面,代码如下
class MyHomePage extends StatefulWidget {
@override
_MyHomePageState createState() => _MyHomePageState();
}
class _MyHomePageState extends State<MyHomePage> {
int _count = 0;
final StreamController<int> _streamController = StreamController();
@override
Widget build(BuildContext context) {
return Scaffold(
body: Container(
child: Center(
child: StreamBuilder<int>(
stream: _streamController.stream,
builder: (BuildContext context, AsyncSnapshot snapshot) {
return snapshot.data == null
? Text("0")
: Text("${snapshot.data}");
}),
),
),
floatingActionButton: FloatingActionButton(
child: const Icon(Icons.add),
onPressed: () {
_streamController.sink.add(++_count);
}),
);
}
@override
void dispose() {
_streamController.close();
super.dispose();
}
}
参考:https://www.cnblogs.com/lxlx1798/p/11126564.html
原文 https://blog.csdn.net/lyhhj/article/details/103937090
在Dart中,一切都是对象,一切对象都是class的实例,哪怕是数字类型、方法甚至null都是对象,所有的对象都是继承自Object;虽然Dart是强类型语言,但变量类型是可选的因为Dart可以自动推断变量类型
Flutter 提升了客户端开发的效率,但在跟 Native 代码配合开发时也带来了不好的体验。于是我写了个 Flutter 插件 dart_objc ,使开发者可以用 Dart 的语法来写 Objective-C 代码。借助于 Flutter 的热重载,也可以更高效的动态调试 Native 代码
今天我们来比较两种在跨平台移动应用开发中最具竞争力的编程语言: Dart Vs JavaScript。Javascript 和 Dart 都是跨平台移动应用程序开发的不错选择
如果你的程序中有两个方法,这两个方法桉顺序执行,第一个方法执行需要五秒,如果是同步代码,第二个方法会等待第一个方法执行完,才会被调用,如果第一个方法是异步的,程序在执行第一个方法时
Dart的所有东西都是对象。它们都继承自Object,默认是都是null。Dart中支持以下数据类型:Dart中提供了两种数值类型, 分别是整型int和浮点型double.但如果是直接定义了 int 或者 double , 那么就不能再赋其他类型的值.
内容以共享、参考、研究为目的,不存在任何商业目的。其版权属原作者所有,如有侵权或违规,请与小编联系!情况属实本人将予以删除!