node 异步 I/O

作者: 小小小超子 | 来源:发表于2018-03-29 23:53 被阅读29次

这篇文章主要讲 nodejs 中的异步 IO,关于同步、异步、阻塞、非阻塞 请移步这里

事件循环 和 消息队列

我们常说“JavaScript是单线程的”。

所谓单线程,是指在JS引擎中负责解释和执行JavaScript代码的线程只有一个。不妨叫它主线程。

但是实际上还存在其他的线程。例如:处理AJAX请求的线程、定时器线程、读写文件的线程等等。这些线程可能存在于JS引擎之内,也可能存在于JS引擎之外,在此我们不做区分。不妨叫它们工作线程。

async_pic.png

node 执行过程

node_event.png

处理并执行完 js 代码,main函数继续往下调用libuv的事件循环入口uv_run(),node进程进入事件循环。 uv_run() 的 while 循环做的就是一件事,判断 default_loop_struct 是否有存活的 io 观察者 或 定时器。

事件循环

事件循环是指主线程重复从消息队列中取消息、执行的过程

事件循环对应上图 3 号标注的部分。用代码表示大概是这样的:

        while(true) {
            var message = queue.get();
            execute(message);
        }
event_loop.png

如上图,每一次执行一次循环体的过程称为 Tick。

事件循环的阶段:

   ┌───────────────────────┐
┌─>│        timers         │ 执行定时器(setTimeout/setInterval)注册的回调函数,也是进入事
│  └──────────┬────────────┘ 件循环第一个阶段。
│  ┌──────────┴────────────┐
│  │     I/O callbacks     │ I/O 事件相关联的回调或者报错会在这里执行
│  └──────────┬────────────┘
│  ┌──────────┴────────────┐
│  │     idle, prepare     │ 内部使用,不讨论
│  └──────────┬────────────┘      ┌───────────────┐
│  ┌──────────┴────────────┐      │   incoming:   │ 最重要的一个阶段,I/O 观察者观察到线程池
│  │         poll          │<─────┤  connections, │ 里有任务已经完成,就会在这里执行回调。
│  └──────────┬────────────┘      │   data, etc.  │
│  ┌──────────┴────────────┐      └───────────────┘
│  │        check          │ 专门用来执行 setImmediate() 的回调
│  └──────────┬────────────┘
│  ┌──────────┴────────────┐
└──┤    close callbacks    │ 一个连接或 handle 突然被关闭,close 事件会被发送到这里执行回调
   └───────────────────────┘

如上图,共有六个阶段(官方称为 phase)。特别要说明的是 poll 阶段,在这个阶段,如果暂时没有事件到来,主线程便会阻塞在这里,等待事件发生。当然它不会一直等下去:

  • 它首先会判断后面的 Check Phase 以及 Close Phase 是否还有等待处理的回调. 如果有, 则不等待, 直接进入下一个 Phase.
  • 如果没有其他回调等待执行, 它会给 epoll 这样的方法设置一个 timeout. 可以猜一下, 这个 timeout 设置为多少合适呢? 答案就是 Timer Phase 中最近要执行的回调启动时间到现在的差值, 假设这个差值是 delta. 因为 Poll Phase 后面没有等待执行的回调了. 所以这里最多等待 delta 时长, 如果期间有事件唤醒了消息循环, 那么就继续下一个 Phase 的工作; 如果期间什么都没发生, 那么到了 timeout 后, 消息循环依然要进入后面的Phase, 让下一个迭代的 Timer Phase 也能够得到执行.

来看一下流程:

phases.png

到这里你一定发现少了一些问题:process.nextTick() 和 Promise 都是异步的,它们对应以上哪个阶段呢?往下看

任务队列

1、运行主线程(函数调用栈)中的同步任务
2、主线程(函数调用栈)执行到任务源时,通知相应的webAPIs进行相应的执行异步任务,将任务源指定的异步任务放入任务队列中
3、主线程(函数调用栈)中的任务执行完毕后,然后执行所有的微任务,再执行宏任务,找到一个任务队列执行完毕,再执行所有的微任务
4、不断执行第三步

任务队列也叫消息队列。主要分两类任务:宏任务(macro-task)、微任务(micro-task)

宏任务:setTimeout setInterval setImmediate I/O

微任务:process.nextTick Promise 的回调

在上面的图中,各个 phase 完成了宏任务对应的事件。微任务的执行时机在每一次进入下一个阶段之前,process.nextTick 优先级大于 Promise 的回调。

FAQ

setTimeout 和 setImmediate 的比较
setImmediate(() => console.log(2))
setTimeout(() => console.log(1))

这段代码的结果实际上是不确定的。可是,为什么?按照流程图,应该是 timer 先于 check 阶段,所以应该是 setTimeout 先执行,可是为什么结果不是这样呢?首先我们要知道:

setTimeout(fn) ==> setTimeout(fn, 0) ==> setTimeout(fn, 1)

上面三个效果是一样的!前两个好理解,给定的默认值是0。其实在 node 源码中,最低为 1 ms,官方文档如下:

When delay is larger than 2147483647 or less than 1, the delay will be set to 1.

所以当进入 timer 阶段时,1ms 可能超时也可能没有,这个影响因素有很多。如果还没超时,则进入下一个 phase,依次往下,所以先输出 2 。如果已经超时,则先输出 1。

但是!如果它们在 I/O 事件回调中,那么输出顺序是固定了的,如下

require('fs').readFile('path.txt', () => {
 setImmediate(() => console.log(2))
 setTimeout(() => console.log(1))
});
// 输出: 2 1

如果不知道为什么,答案就在循环图中。

(完)

Reference

相关文章

  • Node 简介

    Node的特点 Node的特点有:异步I/O、事件与回调函数、单线程、跨平台 异步I/O 在Node中,异步I/O...

  • 3、Node的异步I/O执行回调

    续上前面的 Node的异步I/O Node的异步I/O——请求对象 在组装好请求对象、送入I/O线程池中等待执行,...

  • Node.js 调用栈

    Node.js 是异步非阻塞I/O的。如何解释 Node.js 即是单线程又是异步且非阻塞I/O的,需要理解 No...

  • node 异步 I/O

    这篇文章主要讲 nodejs 中的异步 IO,关于同步、异步、阻塞、非阻塞 请移步这里。 事件循环 和 消息队列 ...

  • node异步I/O

    让I/O与CPU计算并行 Node 在*nix平台,通过线程池实现(主线程和I/O线程),在windows下使用I...

  • 前端进阶全栈-Node的异步IO

    本文力图详尽解释node的异步IO: 异步IO的产生背景 Node中的异步IO具体的实现 非I/O的异步API 一...

  • 异步I/O

    为什么要异步I/O 异步I/O、事件驱动、单线程构成了Node的基调,Node可以作为服务器端去处理客户端带来的大...

  • 如何理解非阻塞I/O(详解)

    node有三大特征:单线程、非阻塞I/O,事件驱动 非阻塞I/O 非阻塞 I/O,也叫异步 I/O,显然对应的就是...

  • node教程--回调函数

    node异步读取文件: node同步读取文件: 在 Node.js 中,异步式 I/O 是通过回调函数来实现的 f...

  • NODE核心概念 (1) - 同步I/O与异步I/O

    Node.js自诞生之日起就以起高并发得名,其中的核心便是异步I/O了。那么到底什么是异步I/O?和传统的同步I/...

网友评论

    本文标题:node 异步 I/O

    本文链接:https://www.haomeiwen.com/subject/pifbcftx.html