事件驅(qū)動模型

現(xiàn)在我們來看看nodejs中的事件驅(qū)動和異步I/O是如何實現(xiàn)的.

nodejs是單線程(single thread)運行的，通過一個事件循環(huán)(event-loop)來循環(huán)取出消息隊列(event-queue)中的消息進行處理,處理過程基本上就是去調(diào)用該消息對應(yīng)的回調(diào)函數(shù)。消息隊列就是當一個事件狀態(tài)發(fā)生變化時，就將一個消息壓入隊列中。

nodejs的時間驅(qū)動模型一般要注意下面幾個點：

1. 因為是單線程的，所以當順序執(zhí)行js文件中的代碼的時候，事件循環(huán)是被暫停的。
2. 當js文件執(zhí)行完以后，事件循環(huán)開始運行，并從消息隊列中取出消息，開始執(zhí)行回調(diào)函數(shù)
3. 因為是單線程的，所以當回調(diào)函數(shù)被執(zhí)行的時候，事件循環(huán)是被暫停的
4. 當涉及到I/O操作的時候，nodejs會開一個獨立的線程來進行異步I/O操作，操作結(jié)束以后將消息壓入消息隊列。

下面我們從一個簡單的js文件入手，來看看 nodejs是如何執(zhí)行的。

var fs = require("fs");
var debug = require('debug')('example1');

debug("begin");

fs.readFile('package.json','utf-8',function(err,data){
 if(err) 
  debug(err);
 else
  debug("get file content");
});

setTimeout(function(){
 debug("timeout2");
});

 
debug('end'); // 運行到這里之前，事件循環(huán)是暫停的

1. 同步執(zhí)行debug("begin")
2. 異步調(diào)用fs.readFile()，此時會開一個新的線程去進行異步I/O操作
3. 異步調(diào)用setTimeout()，馬上將超時信息壓入到消息隊列中
4. 同步調(diào)用debug("end")
5. 開啟事件循環(huán)，彈出消息隊列中的信息(目前是超時信息)
6. 然后執(zhí)行信息對應(yīng)的回調(diào)函數(shù)(事件循環(huán)又被暫停)
7. 回調(diào)函數(shù)執(zhí)行結(jié)束后，開始事件循環(huán)(目前消息隊列中沒有任何東西，文件還沒讀完)
8. 異步I/O讀取文件完畢，將消息壓入消息隊列(消息中含有文件內(nèi)容或者是出錯信息)
9. 事件循環(huán)取得消息，執(zhí)行回調(diào)
10. 程序退出。

以上就是本文的全部內(nèi)容，希望對大家的學習有所幫助，也希望大家多多支持腳本之家。

最新評論