dart中的事件队列与微任务

2024-03-03 05:36
文章标签 任务 dart 事件队列

本文主要是介绍dart中的事件队列与微任务,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

        dart在每个事件循环中,会先执行同步任务代码,然后分别检查两个任务队列:微任务队列和事件队列。dart总是先执行微任务队列中的代码,然后才是事件队列中的代码。当两个队列中的任务都执行完成后,线程进入休眠状态, 等待下一次消息循环的到来。 

        事件队列(event queue),包含所有的外来事件:I/O、mouse events、drawing events、timers、isolate之间的信息传递。

        Future中的任务会加入下一轮的任务队列,then中的任务则是也会加入同样的任务队列。 Future中的任务和then后的任务可以理解为同步任务,因此,若Future嵌套微任务,会优先执行then中的代码, 然后分别是微任务队列中的代码、事件队列中的代码。

        当前事件循环中的微任务,会在这一轮中继续执行。当前事件循环中嵌套的Future中的代码, 才会在下一轮事件循环中执行。

         Future 是链式调用,意味着Future 的 then 未执行完,下一个then 不会执行。

        看一个简单的例子:

void testFuture(){print('外部代码1');Future(()=>print('A')).then((value) => print('A结束'));Future(()=>print('B')).then((value) => print('B结束'));scheduleMicrotask((){print('微任务A');});sleep(Duration(seconds: 1));print('外部代码2');
}

        打印结果:
        外部代码1
        外部代码2
        微任务A
         A
         A结束
         B
         B结束

        再看一个复杂点的例子:

void testFuture4(){Future x1 = Future(()=>null);x1.then((value){print('6');scheduleMicrotask(()=>print('7'));}).then((value) => print('8'));Future x = Future(()=>print('1'));x.then((value){print('4');Future(()=>print('9'));}).then((value) => print('10'));Future(()=>print('2'));scheduleMicrotask(()=>print('3'));print('5');
}

        打印结果:
        5,3,  6,8,7, 1,4,10,2  ,9

        注意: 8先于7执行,因为已经调度到了当前队列中,8在6之后是立刻执行的,而7是异步执行的。  
        注意: 9不是在10之后执行,因为9是在嵌套中下一层的队列中,因此需要等下一个消息循环才会执行。

        再看一个例子:

void testFuture() {Future f1 = new Future(() => print('f1'));Future f2 = new Future(() =>  null);Future f3 = new Future.delayed(Duration(seconds: 1) ,() => print('f2'));Future f4 = new Future(() => null);Future f5 = new Future(() => null);f5.then((_) => print('f3'));f4.then((_) {print('f4');new Future(() => print('f5'));f2.then((_) {print('f6');});});f2.then((m) {print('f7');});print('f8');
}

        执行顺序: f8 、f1 、f7 、f4、f6、f3、f5、f2

        因此可以解释:f4之后为什么直接是f6? 因为f2在前面已经执行过了,所以f6可以理解为一个同步任务,会被立刻执行。

        再看一个更复杂的例子:

void testScheduleMicrotatsk() {scheduleMicrotask(() => print('1'));
//1.0new Future.delayed(new Duration(seconds: 1), () => print('2'));
//2.0new Future(() => print('3')).then((_) {print('4');scheduleMicrotask(() => print('5'));}).then((_) => print('6'));
//3.0new Future(() => print('7')).then((_) => new Future(() => print('8'))).then((_) => print('9'));
//3.1      
//new Future(() => print('7'))
//      .then( (_) { new Future( () => print('8') );})
//      .then( (_) => print('9') ) ;
//4.0new Future(() => print('10'));scheduleMicrotask(() => print('11'));print('12');
}

        注意:如果按照3.0的写法, 执行完7后, 由于then是直接返回一个Future,而不是嵌套一个新Future,9将被阻塞, 因此执行顺序为:12、1、11、3、4 、6、5、7、10、8、9 、2

        3.0的写法等同于下述写法, then中是返回一个Future,而不是嵌套一个新的Future

new Future(() => print('7')).then( (_) { Future f = new Future( () => print('8') );return f;}).then( (_) => print('9') ) ;

        而如果是3.1的写法,则不会阻塞。 因为3.1这里then是嵌套了一个新的Future, 与then直接返回一个Future不同。 其执行顺序为12,1,11,3,4,6,5,7,9,10,8,2。

这篇关于dart中的事件队列与微任务的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/768605

相关文章

FreeRTOS学习笔记(二)任务基础篇

提示:文章写完后,目录可以自动生成,如何生成可参考右边的帮助文档 文章目录 前言一、 任务的基本内容1.1 任务的基本特点1.2 任务的状态1.3 任务控制块——任务的“身份证” 二、 任务的实现2.1 定义任务函数2.2 创建任务2.3 启动任务调度器2.4 任务的运行与切换2.4.1 利用延时函数2.4.2 利用中断 2.5 任务的通信与同步2.6 任务的删除2.7 任务的通知2

Flink任务重启策略

概述 Flink支持不同的重启策略,以在故障发生时控制作业如何重启集群在启动时会伴随一个默认的重启策略,在没有定义具体重启策略时会使用该默认策略。如果在工作提交时指定了一个重启策略,该策略会覆盖集群的默认策略默认的重启策略可以通过 Flink 的配置文件 flink-conf.yaml 指定。配置参数 restart-strategy 定义了哪个策略被使用。常用的重启策略: 固定间隔 (Fixe

第49课 Scratch入门篇:骇客任务背景特效

骇客任务背景特效 故事背景:   骇客帝国特色背景在黑色中慢慢滚动着! 程序原理:  1 、 角色的设计技巧  2 、克隆体的应用及特效的使用 开始编程   1、使用 黑色的背景: ![在这里插入图片描述](https://i-blog.csdnimg.cn/direct/7d74c872f06b4d9fbc88aecee634b074.png#pic_center)   2

AsyncTask 异步任务解析

1:构建AsyncTask 子类的回调方法: A:doInBackground:   必须重写,所有的耗时操作都在这个里面进行; B: onPreExecute:     用户操作数据前的调用; 例如:显示一个进度条 等 ; C: onPostExecute:    当doInBackground 执行完成后;会自动把数据传给onPostExecute方法;也就是说:这个方法是处理返回的数据的方法

使用Node-API进行异步任务开发

一、Node-API异步任务机制概述         Node-API异步任务开发主要用于执行耗时操作的场景中使用,以避免阻塞主线程,确保应用程序的性能和响应效率。         1、应用场景: 文件操作:读取大型文件或执行复杂的文件操作时,可以使用异步工作项来避免阻塞主线程。网络请求:当需要进行网络请求并等待响应时,可以使用异步工作项来避免阻塞主线程,从而提高应用程序的响应性能。数据库操

探索Invoke:Python自动化任务的瑞士军刀

文章目录 探索Invoke:Python自动化任务的瑞士军刀背景:为何选择Invoke?`invoke`是什么?如何安装`invoke`?简单的`invoke`库函数使用方法场景应用:`invoke`在实际项目中的使用场景一:自动化测试场景二:代码格式化场景三:部署应用 常见问题与解决方案问题一:命令执行失败问题二:权限不足问题三:并发执行问题 总结 探索Invoke:P

RISC-V (十)任务同步和锁

并发与同步 并发:指多个控制流同时执行。         多处理器多任务。一般在多处理器架构下内存是共享的。           单处理器多任务,通过调度器,一会调度这个任务,一会调度下个任务。  共享一个处                                理器一个内存。                 单处理器任务+中断: 同步: 是为了保证在并发执行的环境中各个控制流可

145-Linux权限维持Rootkit后门Strace监控Alias别名Cron定时任务

参考 【权限维持】Linux&Rootkit后门&Strace监控&Alias别名&Cron定时任务_alias ls='alerts(){ ls $* --color=auto;python -c "-CSDN博客 参考 FlowUs 息流 - 新一代生产力工具 权限维持-Linux-定时任务-Cron后门 利用系统的定时任务功能进行反弹Shell 1、编辑后门反弹shell脚本

环形定时任务 原理

业务背景 在稍微复杂点业务系统中,不可避免会碰到做定时任务的需求,比如淘宝的交易超时自动关闭订单、超时自动确认收货等等。对于一些定时作业比较多的系统,通常都会搭建专门的调度平台来管理,通过创建定时器来周期性执行任务。如刚才所说的场景,我们可以给订单创建一个专门的任务来处理交易状态,每秒轮询一次订单表,找出那些符合超时条件的订单然后标记状态。这是最简单粗暴的做法,但明显也很low,自己都下不去手写

Spring 创建定时任务

我们在编写Spring Boot应用中经常会遇到这样的场景,比如:我需要定时地发送一些短信、邮件之类的操作,也可能会定时地检查和监控一些标志、参数等。 创建定时任务 在Spring Boot中编写定时任务是非常简单的事,下面通过实例介绍如何在Spring Boot中创建定时任务,实现每过5秒输出一下当前时间。 在Spring Boot的主类中加入@EnableScheduling注解,启用定