跟着大佬走——node中的eventloop
废话不多说,书接上文。忘记前文内容的小伙伴,这里附上链接:
node 中的 eventloop
node 也是单线程,在处理 eventloop 上与浏览器稍有不同,从 API 层面来看,node 增加了两个方法process.nextTick
,setImmediate
前文中我们提到过,node 中 eventloop 是基于 libuv 的库,那么这个库的实现机制是什么呢?
官网[1]对此的解释为:
“
定时器(timers):本阶段执行已经被 setTimeout()
和setInterval()
的调度回调函数。待定回调(pending callbacks):执行延迟到下一个循环迭代的 I/O 回调。 idle, prepare:仅系统内部使用。 轮询(poll):检索新的 I/O 事件;执行与 I/O 相关的回调(几乎所有情况下,除了关闭的回调函数,那些由计时器和 setImmediate()
调度的之外),其余情况 Node 将在适当的时候在此阻塞。检测(check): setImmediate()
回调函数在这里执行。关闭的回调函数(close callbacks):一些关闭的回调函数,如:socket.on('close', ...)。
setTimeout & setImmediate
show me the code:
setTimeout(() => {
console.log('timeout');
}, 0);
setImmediate(() => {
console.log('immediate');
});
node 环境下运行结果为:
timeout
immediate
或者
immediate
timeout
想不到吧,我们来看下官方解释:
首先,执行计时器的顺序将根据调用它们的上下文而异。
其次,若从主模块内部调用,择机时期受进程约束。
若在 I/O 循环内,那么setImmediate
总是被有限次调用。
借用一位博主的话解释就是:
使用 setImmediate 相对 setTimeout 的优势主要在于:无论存在多少个定时器,在 IO 周期内,setImmediate 总是在所有定时器前执行。[2]
process.nextTick()
这个 api 类似昨天文章中的 Promise
或是 MutationObserver
微任务实现,在代码块中可以随时插保证在下一个宏任务开始前执行。
show me the code:
class Lib extends require('events').EventEmitter {
constructor () {
super()
this.emit('init')
}
}
const lib = new Lib()
lib.on('init', _ => {
console.log('init!')
})
上方代码段可看出,console 永远不会执行。让我们看看,怎么用process.nextTick
搞定输出问题:
class Lib extends require('events').EventEmitter {
constructor () {
super()
process.nextTick(_ => {
this.emit('init')
})
}
}
是不是很简单!当 node 主线程执行完毕后,程序触发 eventloop 流程查找有误微任务,发现微任务队列不为空时,则发送 init 事件。
浏览器端可用 Promise.resolve() 实现同样效果。
参考资料
1: https://nodejs.org/en/docs/guides/event-loop-timers-and-nexttick/#event-loop-explained,
[2]2: https://juejin.cn/post/6844904021296316429#heading-8,