node中的事件循环

异步I/O

node最大的特性就是基于事件驱动的非阻塞I/O模型,非阻塞使得CPU和I/O不相互依赖等待,在实现中,分为两步
1、请求对象
在js代码中调用异步I/O,分解步骤可以理解为js调用node的核心模块,核心模块调用C++内建模块,内建模块通过libuv层调用系统。在libuv层进行了请求对象的封装(传入的参数,当前的方法,回调函数),最后将这个对象推入线程池中等待。
2、执行回调
事件循环每次询问是否有事件需要执行,是询问了了观察者,观察者调用IOCP检查线程池中是否有执行完的请求,有则将请求对象加入到事件队列中当做事件处理。回调行为就是取出请求对象的result属性和回调函数调用执行。

  • 所以在node中回调函数并不是由开发者来调用的,而是由事件循环来调用。
  • 单线程和线程池:node本身其实是多线程的,除了js是单线程的外,node所有的I/O(磁盘和网络)都是可以并行的。

非I/O的异步API

1、定时器setTimeout和setInterval创建的定时器会被插入到定时器观察者内部的一个红黑树中,内次Tick执行时会将该红黑树中取出定时器对象,检查是否超过形成事件作为回调函数执行。由于定时器需要红黑树,创建定时器和迭代等操作,对比起来,process.nextTick()方法直接将回调函数放到事件队列中,更轻量。时间复杂度为O(lgn) 和O(1)。
2、setImmediate()属于check观察者,不需要红黑树,在每一个轮的循环检查中,idle观察者 > I/O观察者 > check观察者
3、proces.nextTick()属于idle观察者,每次会追加在当前事件循环的队尾(类似微任务)

  • 相比于同步式、每进程每请求、每线程每请求,事件驱动的方式不会阻塞CPU,也无需为每个请求创建额外对应的线程,在响应和处理业务上拥有独特的高性能。

node中处理异步I/O(与浏览器不同)

图解: https://www.jianshu.com/p/deedcbf68880

不同于浏览器中明晰的js执行栈、微任务和宏任务三种任务队列,node中自有一套执行的方案。首先执行同步任务,发出异步请求,发出定时器,执行nextTick+promise,然后进入事件循环。由于process.nextTick方法指定的回调函数,总是在当前"执行栈"的尾部触发,所以如果有多个process.nextTick语句(不管它们是否嵌套),将全部在当前"执行栈"执行。setImmediate总是将事件注册到下一轮Event Loop,多个setImmediate可能则需要多次loop才能执行完。

事件循环中有六个阶段,分析三个,其他三个由于是内部调用或不常见可以忽略

阶段 事件 执行
timers setTimeout setInterval 事件循环开始,执行所有的宏任务,后执行所有的微任务
=> pending callbacks(内部调用)=> idle, prepare(内部调用) =>
poll 其他 MacroTask(基于事件订阅完成的API 网络请求或IO操作) 执行所有的宏任务,后执行所有的微任务,完成后,if(check){check},else if(timers){则将绕回timers阶段}else if(timers和check都为空),则阻塞在poll阶段等待,大部分的IO callback在此执行而pending callbacks执行的是上次延迟的一些回调
check setImmidate 执行所有的宏任务,后执行所有的微任务
close callbacks socket关闭 执行所有的宏任务,后执行所有的微任务,到此执行完一个tick,返回timers
  • process.nextTick 本质上属于 MicroTask,但是它先于所有其他 MicroTask(promise) 执行;
    所有 MicroTask 的执行时机,是不同类型 MacroTask 切换的时候。

注:setImmediate()具有最高优先级,只要poll队列为空,代码被setImmediate(),无论是否有timers达到下限时间,setImmediate()的代码都先执行。

更多:https://segmentfault.com/a/1190000013102056


举个栗子:

setTimeout(() => {
  console.log('timeout')
}, 0)
// 下限的时间有一个范围:[1, 2147483647],如果设定的时间不在这个范围,将被设置为1。
setImmediate(() => {
  console.log('immediate')
})

在node中这段代码的输出是不确定先后顺序的,首先进入timer阶段,这跟机器性能有关

  • 情况一:如果机器性能一般,在进入timers之前已经过去了1ms,那么将直接把回调函数推入timer队列,进入timers时则会直接执行timers的回调函数;
  • 情况二:如果在进入timers之前还没有过去1ms,timers可执行回调队列为空,则进入poll阶段,poll队列为空,此时检查是否有代码被setImmediate(),于是执行check回调,此次Tick结束,在下一个事件循环timer中执行setTimeout回调。

首先进入的是timers阶段,如果我们的机器性能一般,那么进入timers阶段,一毫秒已经过去了(setTimeout(fn, 0)等价于setTimeout(fn, 1)),那么setTimeout的回调会首先执行。

如果没有到一毫秒,那么在timers阶段的时候,下限时间没到,setTimeout回调不执行,事件循环来到了poll阶段,这个时候队列为空,此时有代码被setImmediate(),于是先执行了setImmediate()的回调函数,之后在下一个事件循环再执行setTimemout的回调函数。

栗子2:

var fs = require('fs')

fs.readFile(__filename, () => {
    setTimeout(() => {
        console.log('timeout');
    }, 0);
    setImmediate(() => {
        console.log('immediate');
    });
});

这里我们就会发现,setImmediate永远先于setTimeout执行。

原因如下:

fs.readFile的回调是在poll阶段执行的,当其回调执行完毕之后,poll队列为空,而setTimeout入了timers的队列,此时有代码被setImmediate(),于是事件循环先进入check阶段执行回调,之后在下一个事件循环再在timers阶段中执行有效回调。

所以只要不是在事件循环开始之前,有timer被推入的操作,只要已经进入了事件循环,进入了poll阶段,setImmediate将会先执行。

  • 如果两者都在主模块中调用,那么执行先后取决于进程性能,也就是随机。
  • 如果两者都不在主模块调用,那么setImmediate的回调永远先执行。
同样的
setTimeout(() => {
    setImmediate(() => {
        console.log('setImmediate');
    });
    setTimeout(() => {
        console.log('setTimeout');
    }, 0);
}, 0);

以上的代码在timers阶段执行外部的setTimeout回调后,内层的setTimeout和setImmediate入队,之后事件循环继续往后面的阶段走,走到poll阶段的时候发现队列为空,此时有代码被setImmedate(),所以直接进入check阶段执行响应回调(注意这里没有去检测timers队列中是否有成员到达下限事件,因为setImmediate()优先)。之后在第二个事件循环的timers阶段中再去执行相应的回调。

另外的

setImmediate(() => {
    setImmediate(() => {
        console.log('setImmediate');
    });
    setTimeout(() => {
        console.log('setTimeout');
    }, 0);
}, 0);

setImmediate()实际上是一个特殊的timer,跑在事件循环中的一个独立的阶段。它使用libuv的API来设定在poll阶段结束后立即执行回调。

注:setImmediate()具有最高优先级,只要poll队列为空,代码被setImmediate(),无论是否有timers达到下限时间,setImmediate()的代码都先执行。

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 212,080评论 6 493
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 90,422评论 3 385
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 157,630评论 0 348
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 56,554评论 1 284
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 65,662评论 6 386
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 49,856评论 1 290
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 39,014评论 3 408
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 37,752评论 0 268
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 44,212评论 1 303
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 36,541评论 2 327
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 38,687评论 1 341
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 34,347评论 4 331
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 39,973评论 3 315
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 30,777评论 0 21
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 32,006评论 1 266
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 46,406评论 2 360
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 43,576评论 2 349

推荐阅读更多精彩内容

  • 为什么要异步I/O 异步I/O、事件驱动、单线程构成了Node的基调,Node可以作为服务器端去处理客户端带来的大...
    Upcccz阅读 1,574评论 0 0
  • 1.为什么要使用异步I/O 1.1 用户体验 浏览器中的Javascripts是在单线程上执行的,并且和UI渲染公...
    maikuraki阅读 542评论 0 0
  • 为什么要异步 I/O 用户体验 只有后端能够快速响应资源,才能让前端的体验变好 资源分配 利用单线程,远离多线程死...
    茂茂爱吃鱼阅读 568评论 0 0
  • Node的异步I/O 我们为什么需要异步I/O? 用户体验服务器端如果基于同步执行的,随着应用复杂性的增加,响应的...
    俗三疯阅读 497评论 0 0
  • topics: 1.The Node.js philosophy 2.The reactor pattern 3....
    宫若石阅读 1,064评论 0 1