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

相关文章

Spring定时任务只执行一次的原因分析与解决方案

《Spring定时任务只执行一次的原因分析与解决方案》在使用Spring的@Scheduled定时任务时,你是否遇到过任务只执行一次,后续不再触发的情况?这种情况可能由多种原因导致,如未启用调度、线程... 目录1. 问题背景2. Spring定时任务的基本用法3. 为什么定时任务只执行一次?3.1 未启用

如何使用Python实现一个简单的window任务管理器

《如何使用Python实现一个简单的window任务管理器》这篇文章主要为大家详细介绍了如何使用Python实现一个简单的window任务管理器,文中的示例代码讲解详细,感兴趣的小伙伴可以跟随小编一起... 任务管理器效果图完整代码import tkinter as tkfrom tkinter i

Spring Boot 集成 Quartz 使用Cron 表达式实现定时任务

《SpringBoot集成Quartz使用Cron表达式实现定时任务》本文介绍了如何在SpringBoot项目中集成Quartz并使用Cron表达式进行任务调度,通过添加Quartz依赖、创... 目录前言1. 添加 Quartz 依赖2. 创建 Quartz 任务3. 配置 Quartz 任务调度4. 启

Java使用多线程处理未知任务数的方案介绍

《Java使用多线程处理未知任务数的方案介绍》这篇文章主要为大家详细介绍了Java如何使用多线程实现处理未知任务数,文中的示例代码讲解详细,感兴趣的小伙伴可以跟随小编一起学习一下... 知道任务个数,你可以定义好线程数规则,生成线程数去跑代码说明:1.虚拟线程池:使用 Executors.newVir

Spring Boot中定时任务Cron表达式的终极指南最佳实践记录

《SpringBoot中定时任务Cron表达式的终极指南最佳实践记录》本文详细介绍了SpringBoot中定时任务的实现方法,特别是Cron表达式的使用技巧和高级用法,从基础语法到复杂场景,从快速启... 目录一、Cron表达式基础1.1 Cron表达式结构1.2 核心语法规则二、Spring Boot中定

Spring Boot 整合 ShedLock 处理定时任务重复执行的问题小结

《SpringBoot整合ShedLock处理定时任务重复执行的问题小结》ShedLock是解决分布式系统中定时任务重复执行问题的Java库,通过在数据库中加锁,确保只有一个节点在指定时间执行... 目录前言什么是 ShedLock?ShedLock 的工作原理:定时任务重复执行China编程的问题使用 Shed

Python Invoke自动化任务库的使用

《PythonInvoke自动化任务库的使用》Invoke是一个强大的Python库,用于编写自动化脚本,本文就来介绍一下PythonInvoke自动化任务库的使用,具有一定的参考价值,感兴趣的可以... 目录什么是 Invoke?如何安装 Invoke?Invoke 基础1. 运行测试2. 构建文档3.

解决Cron定时任务中Pytest脚本无法发送邮件的问题

《解决Cron定时任务中Pytest脚本无法发送邮件的问题》文章探讨解决在Cron定时任务中运行Pytest脚本时邮件发送失败的问题,先优化环境变量,再检查Pytest邮件配置,接着配置文件确保SMT... 目录引言1. 环境变量优化:确保Cron任务可以正确执行解决方案:1.1. 创建一个脚本1.2. 修

Java实现任务管理器性能网络监控数据的方法详解

《Java实现任务管理器性能网络监控数据的方法详解》在现代操作系统中,任务管理器是一个非常重要的工具,用于监控和管理计算机的运行状态,包括CPU使用率、内存占用等,对于开发者和系统管理员来说,了解这些... 目录引言一、背景知识二、准备工作1. Maven依赖2. Gradle依赖三、代码实现四、代码详解五

如何使用celery进行异步处理和定时任务(django)

《如何使用celery进行异步处理和定时任务(django)》文章介绍了Celery的基本概念、安装方法、如何使用Celery进行异步任务处理以及如何设置定时任务,通过Celery,可以在Web应用中... 目录一、celery的作用二、安装celery三、使用celery 异步执行任务四、使用celery