Nodejs Q promise實(shí)現(xiàn)初探

前言

Q庫(kù)為nodejs提供了一個(gè)基于promise的編程方式,從此避免了一層又一層的callback調(diào)用。不過(guò)Q的靈活性也給我造成了很大困擾,我可以用promise去resolve promise么,我在then里return promise可以么?因此我研究了下Q庫(kù)的源代碼,幸運(yùn)的是,Q庫(kù)提供了一份詳細(xì)的設(shè)計(jì)文檔,極大的方便了我們對(duì)其設(shè)計(jì)思路的理解。

直接開(kāi)始

跳過(guò)一些最原始的版本,我們先看看根據(jù)promise的最基本工作方式,能想到的最簡(jiǎn)單的promise實(shí)現(xiàn)。

    var defer = function () {
        var pending = [], value;
        return {
            resolve: function (_value) {
                value = _value;
                for (var i = 0, ii = pending.length; i < ii; i++) {
                    var callback = pending[i];
                    callback(value);
                }
                pending = undefined;
            },
            then: function (callback) {
                if (pending) {
                    pending.push(callback);
                } else {
                    callback(value);
                }
            }
        }
    };

在defer里存儲(chǔ)函數(shù),傳遞到then里的callback會(huì)在原defer被resolve時(shí)觸發(fā),這是最直觀的promise實(shí)現(xiàn)方式。
這種實(shí)現(xiàn)方式無(wú)法實(shí)現(xiàn)鏈接,defer.promise.then.then.then是不能實(shí)現(xiàn)的,另外defer.resolve只能用實(shí)值而不能用promise。

為了能夠?qū)romise鏈接起來(lái),then函數(shù)必須也return一個(gè)promise,為了能夠用promise去resolve defer。q提供了一個(gè)對(duì)實(shí)值的封裝。

    var ref = function (value) {
        if (value && typeof value.then === "function")
            return value;
        return {
            then: function (callback) {
                callback(value);
            }};
    };

如果value本身為promise,就返回該promise,如果該value為實(shí)值,就返回一個(gè)已經(jīng)被resolve了的promise,resolve value就是這個(gè)實(shí)值。

    var ref = function (value) {
        if (value && typeof value.then === "function")
            return value;
        return {
            then: function (callback) {
                return ref(callback(value));
            }};
    };

這個(gè)版本將callback的返回值也封裝成promise,因此then函數(shù)的返回值可以繼續(xù)用then繼續(xù)鏈接下去。不過(guò)我們還沒(méi)法用promise去resolve defer,因此引出了下面這個(gè)版本。

    var defer = function () {
    var pending = [], value;
    return {
        resolve: function (_value) {
            if (pending) {
                value = ref(_value); // values wrapped in a promise
                for (var i = 0, ii = pending.length; i < ii; i++) {
                    var callback = pending[i];
                    value.then(callback); // then called instead
                }
                pending = undefined;
            }
        },
        promise: {
            then: function (_callback) {
                var result = defer();
                // callback is wrapped so that its return
                // value is captured and used to resolve the promise
                // that "then" returns
                var callback = function (value) {
                    result.resolve(_callback(value));
                };
                if (pending) {
                    pending.push(callback);
                } else {
                    value.then(callback);
                }
                return result.promise;
            }
        }
    };
};

在resolve一個(gè)defer時(shí),defer會(huì)將該value封裝成一個(gè)promise。然后會(huì)將目前存儲(chǔ)的callbacks傳遞到該promise的then函數(shù)中,callback函數(shù)的調(diào)用時(shí)機(jī)取決于該promise的resolve時(shí)刻了。
注意,這里存儲(chǔ)的callback也不是通過(guò)then函數(shù)傳遞進(jìn)來(lái)的callback了,為了實(shí)現(xiàn)then的鏈接,存儲(chǔ)的callback做的實(shí)際事情是調(diào)用傳遞進(jìn)來(lái)的callback,并且用結(jié)果去resolve內(nèi)部新建的一個(gè)defer,并且then函數(shù)返回該新建defer的promise。
簡(jiǎn)而言之,then里面?zhèn)鬟f的callback函數(shù)也可以返回一個(gè)promise,之后的then鏈里只有在該promise被resolve時(shí)才會(huì)被調(diào)用。

因此現(xiàn)在我們的q庫(kù)可以寫(xiě)出如下的調(diào)用方式:

    var deferA = q.defer();
    deferA.promise //promiseA
        .then(function(value){
            //func1
            return promise2;
        })
        .then(function(value){
            //func2
            return promise3;
        });
    defer.resolve(promise1);

這套函數(shù)會(huì)構(gòu)造出一個(gè)鏈條:

 deferA ->promiseA -> hidden_deferA -> call func1 -> promise2 -> hidden_defer2 -> call func2 -> promise3

也就是說(shuō),每次對(duì)一個(gè)promise調(diào)用then時(shí),它就會(huì)創(chuàng)建一個(gè)隱藏的defer,返回這個(gè)defer的promise,當(dāng)原promise被resolve時(shí),該defer也會(huì)被傳遞進(jìn)去的函數(shù)生成的結(jié)果resolve。

到這一步為止,就是q的promise的大概實(shí)現(xiàn)原理了。然而q為了進(jìn)一步抽象和提高,做出了一個(gè)message機(jī)制,以后的文章再仔細(xì)研究。

最后編輯于
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請(qǐng)聯(lián)系作者
【社區(qū)內(nèi)容提示】社區(qū)部分內(nèi)容疑似由AI輔助生成,瀏覽時(shí)請(qǐng)結(jié)合常識(shí)與多方信息審慎甄別。
平臺(tái)聲明:文章內(nèi)容(如有圖片或視頻亦包括在內(nèi))由作者上傳并發(fā)布,文章內(nèi)容僅代表作者本人觀點(diǎn),簡(jiǎn)書(shū)系信息發(fā)布平臺(tái),僅提供信息存儲(chǔ)服務(wù)。

相關(guān)閱讀更多精彩內(nèi)容

友情鏈接更多精彩內(nèi)容