前言
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ì)研究。