1. 程式人生 > >NodeJS實現同步的方法

NodeJS實現同步的方法

inter ews ttr 功能 同步 異步 splay led ng-

NodeJS被打上了單線程、非阻塞、事件驅動…..等標簽。 在單線程的情況下,是無法開啟子線程的。經過了很久的研究,發現並沒有thread函數!!!但是有時候,我們確實需要“多線程”處理事務。nodeJS有兩個很基礎的api:setTimeout和setInterval。這兩個函數都能實現“異步”。 nodeJS的異步實現:nodeJS有一個任務隊列,在使用setInterval函數的時候,會每隔特定的時間向該任務隊列增加任務,從而實現“多任務”處理。但是,“特定的時間”不代表是具體的時間,也有可能是會大於我們設定的時間,也有可能小於。 我們跑跑下面代碼塊

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

輸出的結果如下:

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

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

問題來了,setInterval是能實現多任務的效果,但是怎樣才能實現任務之間的同步操作呢?這裏實現的方法是通過回調函數實現的。

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方法的實現賦值給a方法的callback函數從而實現函數回調,但是會有個問題。假設a方法依賴於b方法,b方法依賴於c方法,c方法依賴於d方法…..也就意味著每個方法的實現都需要持有上一個方法的實例,從而實現回調。

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

如果回調函數寫的多了,會造成代碼特別特別惡心。

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

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

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

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

// 根據b, a, c這樣的順序執行
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模塊的實現的如果了解更多關於async模塊的使用,可以點擊:查看詳情

其實nodeJS基本api也提供了異步實現同步的方式。基於Promise+then的實現

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

console.log(sleep(3000));

輸出結果為:

Promise { <pending> }
end!

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


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任務執行完後,調用了resolve才會執行所有的then函數,並且這些then函數是異步執行的。由輸出結果可以知道。(如果所有then是順序執行的應該是end! -> end!!)。但是上述也做到了兩個異步任務之間順序執行了。

不過,還有更加優雅的方式:使用async+await。

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

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

輸出結果:

b
a
c

由於這裏時間輸出比較尷尬,只能通過我們來感知,本人通過個人“感知”知道了在display b過度到display a的時候大概用了3s,再過度到display c的時候大概用了5s

NodeJS實現同步的方法