NodeJS如何實現(xiàn)同步的方法示例

更新時間：2018年08月24日 10:05:16 作者：gsl222

nodeJS最大的特點就是其異步操作，下面這篇文章主要給大家介紹了關于NodeJS如何實現(xiàn)同步的方法的相關資料，文中通過示例代碼介紹的非常詳細，需要的朋友可以參考借鑒，下面隨著小編來一起學習學習吧

前言

眾所周知，異步是得天獨厚的特點和優(yōu)勢，但同時在程序中同步的需求（比如控制程序的執(zhí)行順序為：func1 -> func2 ->func3 ）也是很常見的。

下面這篇文章主要介紹了關于NodeJS實現(xiàn)同步的相關內容，NodeJS被打上了單線程、非阻塞、事件驅動…..等標簽。在單線程的情況下，是無法開啟子線程的。經(jīng)過了很久的研究，發(fā)現(xiàn)并沒有thread函數(shù)?。?！但是有時候，我們確實需要“多線程”處理事務。nodeJS有兩個很基礎的api：setTimeout和setInterval。這兩個函數(shù)都能實現(xiàn)“異步”。 nodeJS的異步實現(xiàn)：nodeJS有一個任務隊列，在使用setInterval函數(shù)的時候，會每隔特定的時間向該任務隊列增加任務，從而實現(xiàn)“多任務”處理。但是，“特定的時間”不代表是具體的時間，也有可能是會大于我們設定的時間，也有可能小于。

我們跑跑下面代碼塊

setInterval(function() {
 console.log(new Date().getTime());
}, 1000);

輸出的結果如下：

1490531390640
1490531391654
1490531392660
1490531393665
1490531394670
1490531395670
1490531396672
1490531397675
......

我們可以看到，所有的時間間隔都是不一樣的。時間的偏移不僅包含了間隔的1s，還包含了console.log()的耗時，以及new Date()的耗時。在大量的數(shù)據(jù)統(tǒng)計下，時間間隔近似于1s。

問題來了，setInterval是能實現(xiàn)多任務的效果，但是怎樣才能實現(xiàn)任務之間的同步操作呢？

這里實現(xiàn)的方法是通過回調函數(shù)實現(xiàn)的。

function a(callback) {
 // 模擬任務a耗時
 setTimeout(function() {
  console.log("task a end!");
  // 回調任務b
  callback();
 }, 3000);
};

function b() {
 setTimeout(function() {
  console.log("task b end!");
 }, 5000);
}
a(b);

這里舉了一個很簡單的例子，就是將b方法的實現(xiàn)賦值給a方法的callback函數(shù)從而實現(xiàn)函數(shù)回調，但是會有個問題。假設a方法依賴于b方法，b方法依賴于c方法，c方法依賴于d方法…..也就意味著每個方法的實現(xiàn)都需要持有上一個方法的實例，從而實現(xiàn)回調。

function a(b, c, d) {
 console.log("hello a");
 b(c, d);
};

function b(c, d) {
 console.log("hello b");
 c(d);
};

function c(d) {
 console.log("hello c");
 d()
};

function d() {
 console.log("hello d");
};

a(b, c, d);

輸出結果

hello a
hello b
hello c
hello d

如果回調函數(shù)寫的多了，會造成代碼特別特別惡心。

如果有類似于sync的函數(shù)能讓任務順序執(zhí)行就更好了。終于找到了async這個庫 $ npm instanll async

async = require("async");
a = function (callback) {
 // 延遲5s模擬耗時操作
 setTimeout(function () {
  console.log("hello world a");
  // 回調給下一個函數(shù)
  callback(null, "function a");
 }, 5000);
};

b = function (callback) {
 // 延遲1s模擬耗時操作
 setTimeout(function () {
  console.log("hello world b");
  // 回調給下一個函數(shù)
  callback(null, "function b");
 }, 1000);
};

c = function (callback) {
 console.log("hello world c");
 // 回調給下一個函數(shù)
 callback(null, "function c");
};

// 根據(jù)b, a, c這樣的順序執(zhí)行
async.series([b, a, c], function (error, result) {
 console.log(result);
});

注釋基本能夠很好的理解了，我們看看輸出

hello world b
hello world a
hello world c
[ 'function b', 'function a', 'function c' ]

上面的基本async模塊的實現(xiàn)的如果了解更多關于async模塊的使用，可以點擊：查看詳情

其實nodeJS基本api也提供了異步實現(xiàn)同步的方式。基于Promise+then的實現(xiàn)

sleep = function (time) {
 return new Promise(function () {
  setTimeout(function () {
   console.log("end!");
  }, time);
 });
};

console.log(sleep(3000));

輸出結果為:

Promise { <pending> }
end!

可以看出來，這里返回了Promise對象，直接輸出Promise對象的時候，會輸出該對象的狀態(tài)，只有三種：PENDING、FULFILLED、REJECTED。字面意思很好理解。也就是說Promise有可能能實現(xiàn)我們異步任務同步執(zhí)行的功能。我們先用Promise+then結合起來實現(xiàn)異步任務同步操作。

sleep = function () {
 return new Promise(function (resolve, reject) {
  setTimeout(function () {
   console.log("start!");
   resolve();
  }, 1000);
 })
  .then(function () {
   setTimeout(function () {
    console.log("end!");
   }, 2000);
  })
  .then(function () {
   console.log("end!!");
  })
};
console.log(sleep(1000));

輸出結果：

Promise { <pending> }
start!
end!!
end!

在new Promise任務執(zhí)行完后，調用了resolve才會執(zhí)行所有的then函數(shù)，并且這些then函數(shù)是異步執(zhí)行的。由輸出結果可以知道。（如果所有then是順序執(zhí)行的應該是end! -> end!!）。但是上述也做到了兩個異步任務之間順序執(zhí)行了。

不過，還有更加優(yōu)雅的方式：使用async+await。

display = function(time, string) {
 return new Promise(function (resovle, reject) {
  setTimeout(function () {
   console.log(string);
   resovle();
  }, time)
 });
};

// 執(zhí)行順序：b a c
fn = async function () {
 // 會造成阻塞
 await display(5000, "b");
 await display(3000, "a");
 await display(5000, "c");
}();

輸出結果：