nodeJs事件循環(huán)運(yùn)行代碼解析

更新時(shí)間：2023年04月14日 15:19:27 作者：Tomarsh

這篇文章主要為大家介紹了nodeJs事件循環(huán)運(yùn)行代碼解析，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進(jìn)步，早日升職加薪

Nodejs運(yùn)行時(shí)

JS語言是同步，阻塞，單線程的，但是nodejs不是。Nodejs由三個(gè)主要組件：

外部依賴?yán)?v8,libuv,crypto
提供文件和網(wǎng)絡(luò)服務(wù)的c++模塊
基于c++模塊上層封裝的JS庫

nodejs的異步特性主要由libuv提供。libuv是跨平臺(tái)的使用c語言寫的庫，它主要提供對異步操作的支持。

node運(yùn)行時(shí)代碼運(yùn)行

當(dāng)我們在Nodejs中執(zhí)行JS代碼時(shí)，是由v8引擎處理代碼執(zhí)行，v8包括一塊內(nèi)存區(qū)域（堆）和調(diào)用棧。當(dāng)定義函數(shù)，變量時(shí)，從堆中分配內(nèi)存，當(dāng)執(zhí)行代碼時(shí)將函數(shù)入棧，函數(shù)返回時(shí)出棧。

當(dāng)執(zhí)行異步操作時(shí)，libuv將接管該任務(wù)，然后使用操作系統(tǒng)的異步機(jī)制運(yùn)行任務(wù)。如果缺乏系統(tǒng)級(jí)的異步機(jī)制，就使用線程池運(yùn)行任務(wù)，保證主線程不被阻塞。

Event Loop

事件循環(huán)是一個(gè)nodejs應(yīng)用運(yùn)行后一直存在的循環(huán)。存在著六個(gè)不同的隊(duì)列，每個(gè)都存儲(chǔ)著不同的回調(diào)。

Timer queue（定時(shí)器隊(duì)列），最小堆，由setTimeout, setInterval創(chuàng)建
IO隊(duì)列：文件、網(wǎng)絡(luò)操作
check隊(duì)列，任務(wù)由setImmediate產(chǎn)生，node專有
close隊(duì)列，與異步任務(wù)的close事件相關(guān)
nextTick隊(duì)列
promise隊(duì)列

除了兩個(gè)微任務(wù)隊(duì)列，其他隊(duì)列都是libuv自帶的

如何工作？

同步代碼優(yōu)于異步代碼，事件循環(huán)是call stack為空后開始。事件循環(huán)遵循的優(yōu)先級(jí)規(guī)則：

微任務(wù)隊(duì)列有任務(wù)，先處理完。nextTick先于promise
定時(shí)器任務(wù)執(zhí)行
IO隊(duì)列
check隊(duì)列
close隊(duì)列

需要注意的是在定時(shí)器隊(duì)列，IO隊(duì)列，check隊(duì)列，close隊(duì)列執(zhí)行一個(gè)任務(wù)后都會(huì)檢查并運(yùn)行微任務(wù)隊(duì)列。

實(shí)驗(yàn)

實(shí)驗(yàn)1

// index.js
console.log("console.log 1");
process.nextTick(() => console.log("this is process.nextTick 1"));
console.log("console.log 2");

輸出

console.log 1
console.log 2
this is process.nextTick 1

結(jié)論：同步先于異步

實(shí)驗(yàn)2

// index.js
Promise.resolve().then(() => console.log("this is Promise.resolve 1"));
process.nextTick(() => console.log("this is process.nextTick 1"));

輸出

this is process.nextTick 1
this is Promise.resolve 1

結(jié)論: nextTick先于promise

實(shí)驗(yàn)3

// index.js
process.nextTick(() => console.log("this is process.nextTick 1"));
process.nextTick(() => {
  console.log("this is process.nextTick 2");
  process.nextTick(() =>
    console.log("this is the inner next tick inside next tick")
  );
});
process.nextTick(() => console.log("this is process.nextTick 3"));
Promise.resolve().then(() => console.log("this is Promise.resolve 1"));
Promise.resolve().then(() => {
  console.log("this is Promise.resolve 2");
  process.nextTick(() =>
    console.log("this is the inner next tick inside Promise then block")
  );
});
Promise.resolve().then(() => console.log("this is Promise.resolve 3"));

實(shí)驗(yàn)3

// index.js
process.nextTick(() => console.log("this is process.nextTick 1"));
process.nextTick(() => {
  console.log("this is process.nextTick 2");
  process.nextTick(() =>
    console.log("this is the inner next tick inside next tick")
  );
});
process.nextTick(() => console.log("this is process.nextTick 3"));
Promise.resolve().then(() => console.log("this is Promise.resolve 1"));
Promise.resolve().then(() => {
  console.log("this is Promise.resolve 2");
  process.nextTick(() =>
    console.log("this is the inner next tick inside Promise then block")
  );
});
Promise.resolve().then(() => console.log("this is Promise.resolve 3"));

輸出

this is process.nextTick 1
this is process.nextTick 2
this is process.nextTick 3
this is the inner next tick inside next tick
this is Promise.resolve 1
this is Promise.resolve 2
this is Promise.resolve 3
this is the inner next tick inside Promise then block

解析：

nextTick內(nèi)部增加的nextTick任務(wù)還是先于promise，因?yàn)閚exttick隊(duì)列清完后才會(huì)執(zhí)行promise隊(duì)列的任務(wù)。

promise里增加的nextTick任務(wù)晚于其他的promise，因?yàn)榇藭r(shí)是在執(zhí)行promise階段，需要清空promise才會(huì)檢查nextTick隊(duì)列。

實(shí)驗(yàn)4

// index.js
setTimeout(() => console.log("this is setTimeout 1"), 0);
setTimeout(() => {
  console.log("this is setTimeout 2");
  process.nextTick(() =>
    console.log("this is inner nextTick inside setTimeout")
  );
}, 0);
setTimeout(() => console.log("this is setTimeout 3"), 0);
process.nextTick(() => console.log("this is process.nextTick 1"));
process.nextTick(() => {
  console.log("this is process.nextTick 2");
  process.nextTick(() =>
    console.log("this is the inner next tick inside next tick")
  );
});
process.nextTick(() => console.log("this is process.nextTick 3"));
Promise.resolve().then(() => console.log("this is Promise.resolve 1"));
Promise.resolve().then(() => {
  console.log("this is Promise.resolve 2");
  process.nextTick(() =>
    console.log("this is the inner next tick inside Promise then block")
  );
});
Promise.resolve().then(() => console.log("this is Promise.resolve 3"));

輸出

this is process.nextTick 1
this is process.nextTick 2
this is process.nextTick 3
his is the inner next tick inside next tick
this is Promise.resolve 1
this is Promise.resolve 2
this is Promise.resolve 3
this is the inner next tick inside Promise then block
this is setTimeout 1
this is setTimeout 2
this is inner nextTick inside setTimeout
this is setTimeout 3

結(jié)論：

nextTick先于promise；微任務(wù)先于setTimeout；每個(gè)Timer任務(wù)后會(huì)檢查執(zhí)行微任務(wù)。

實(shí)驗(yàn)6

// index.js
setTimeout(() => console.log("this is setTimeout 1"), 1000);
setTimeout(() => console.log("this is setTimeout 2"), 500);
setTimeout(() => console.log("this is setTimeout 3"), 0);

輸出

this is setTimeout 3
this is setTimeout 2
this is setTimeout 1

結(jié)論： Timer隊(duì)列是按時(shí)間排序的

實(shí)驗(yàn)7

// index.js
const fs = require("fs");
fs.readFile(__filename, () => {
  console.log("this is readFile 1");
});
process.nextTick(() => console.log("this is process.nextTick 1"));
Promise.resolve().then(() => console.log("this is Promise.resolve 1"));

輸出

this is process.nextTick 1
this is Promise.resolve 1

結(jié)論：微任務(wù)先于io任務(wù)

實(shí)驗(yàn)8

// index.js
const fs = require("fs");
setTimeout(() => console.log("this is setTimeout 1"), 0);
fs.readFile(__filename, () => {
  console.log("this is readFile 1");
});

輸出

不確定

解析：setTimeout 0通常內(nèi)部會(huì)取1ms，也就是1ms后執(zhí)行Timer任務(wù)，而cpu進(jìn)入事件循環(huán)的時(shí)機(jī)不定，所以有可能進(jìn)入事件循環(huán)時(shí)已經(jīng)過了1ms，那么先執(zhí)行timer任務(wù)，也可能進(jìn)入時(shí)定時(shí)任務(wù)沒到時(shí)間，會(huì)先執(zhí)行IO任務(wù)。

實(shí)驗(yàn)9

// index.js
const fs = require("fs");
fs.readFile(__filename, () => {
  console.log("this is readFile 1");
});
process.nextTick(() => console.log("this is process.nextTick 1"));
Promise.resolve().then(() => console.log("this is Promise.resolve 1"));
setTimeout(() => console.log("this is setTimeout 1"), 0);
for (let i = 0; i < 2000000000; i++) {}

輸出

this is process.nextTick 1
this is Promise.resolve 1
this is setTimeout 1
this is readFile 1

解析：

代碼最后加了循環(huán)保證進(jìn)入事件循環(huán)時(shí)定時(shí)器任務(wù)已經(jīng)到期，所以先執(zhí)行Timer任務(wù)

實(shí)驗(yàn)10

// index.js
const fs = require("fs");
fs.readFile(__filename, () => {
  console.log("this is readFile 1");
});
process.nextTick(() => console.log("this is process.nextTick 1"));
Promise.resolve().then(() => console.log("this is Promise.resolve 1"));
setTimeout(() => console.log("this is setTimeout 1"), 0);
setImmediate(() => console.log("this is setImmediate 1"));
for (let i = 0; i < 2000000000; i++) {}

輸出

this is process.nextTick 1
this is Promise.resolve 1
this is setTimeout 1
this is setImmediate 1
this is readFile 1

解析：按理說IO任務(wù)先于check任務(wù)，但是第一次事件循環(huán)時(shí)IO任務(wù)的callback并不在隊(duì)列里。在兩個(gè)隊(duì)列之間會(huì)通過IO polling的方式去查看io任務(wù)是否完成，完成了就將callback加到隊(duì)列里，然后下一輪循環(huán)時(shí)會(huì)調(diào)用