用了这么长时间的promise,也看了很多关于promise 的文章博客,对promise 算是些了解。但是要更深的理解promise,最好的办法还是自己实现一个。
我大概清楚promise 是对异步概念的包装,当你拿到一个promise 对象,你并不是拿到你想要的值,而只是这个值的一个“承诺”。这个承诺可能被实现,从而你可以拿到最终想要的值,但也可能被拒绝,然后得到原因。关于promise 对编程风格的改善可以网上有很多文章可以参考,比如这篇。
var promise = new Promise(function (resolve, reject) { setTimeout(function(){ resolve(1); }, 1000); }).then(function(n) { var p = new Promise(function(resolve, reject) { setTimeout(function() { resolve(n + 2); }, 2000); }) return p; }).then(function(r) { console.log(r); })
上面是一个使用promise 的例子,整个流程需要经过两个异步操作的处理。第一个异步操作是要花费1秒得到整数1,紧接着花费2秒将前一个操作的返回值加上2。
最后等待所有操作完成后将结果打印。 1 —> 1+2 —> log(3)
既然是异步操作,你怎么能保证then 过去的函数一定被调用呢?如果还没等then 执行就resolve 了,这样怎么保证回调依然被执行的?答案就是:其实promise 是个状态机,初试状态是pending,当异步操作完成后变为resolved,或者被拒绝变为rejected。那么每当我then 的时候,如果是pending 状态就把这个回调存起来,如果是resolve 状态就立即执行这个回调。
为了能一直then 下去,then必须返回一个promise,这样我们可以构造出一系列then 链条,链条上的每个promise 都观察着前一个promise,一旦前一个promise 被实现,后续的一个promise 立即被执行,如此传递下去。当然如果其中一环被拒绝的话,整个链条就断了,后续不再执行。
Version 1:
var PENDING = 0, RESOLVED = 1, REJECTED = 2; function Promise(fn) { var state = PENDING; var value; var callback; var doResolve = function(_value) { if (state === PENDING) { value = _value; state = RESOLVED; if (callback) callback(value); } else { throw new Error("A promise can only been resolved once."); } }var doReject = function(_reason) { state = REJECTED; throw _reason; } this.then = function (_callback) { return new Promise(function (_resolve, _reject) { var dummy_callback = function (_value) { _resolve(_callback(_value)); } if (state === PENDING) { callback = dummy_callback } else { dummy_callback(value); } }); } fn(doResolve, doReject); }
上面的代码实现了一个简单的promise, 但是有一个很严重的问题,无法处理返回promise 的情况(文章开头的那个例子),如果其中一个promise 返回的是另一个promise,那么我们应该把这个新的promise 纳入链条,等待其resolve 后再继续执行剩下的链条。
Version2:
var PENDING = 0, RESOLVED = 1, REJECTED = 2; function Promise(fn) { var state = PENDING; var value; var callback; var doResolve = function(_value) { if (state === PENDING) { value = _value; state = RESOLVED; if (callback) callback(value); } else { throw new Error("A promise can only been resolved once."); } } var real_resolve = function (_value) { if (_value && typeof _value.then === "function") { _value.then(doResolve); } else { doResolve(_value); } } var doReject = function(_reason) { state = REJECTED; throw _reason; } this.then = function (_callback) { return new Promise(function (_resolve, _reject) { var dummy_callback = function (_value) { _resolve(_callback(_value)); } if (state === PENDING) { callback = dummy_callback } else { dummy_callback(value); } }); } fn(real_resolve, doReject); }
我在doResolve 之前加了一个real_resolve 用来处理万一reolsve一个promise 的情况,这里投了一个懒,直接调用了value.then 创建一个新的promise 加入链条。但是本质上可以用value本身。虽然有待改进,但是目的已经达到了,这就是一个简单的promise 实现。
参考:https://www.promisejs.org/implementing/
https://github.com/kriskowal/q/blob/v1/design/README.js