首页 > 代码库 > jQuery源码学习:Deferred Object
jQuery源码学习:Deferred Object
本文所有讨论均基于jQuery版本3.1.1,官网http://jquery.com/。
一.Deferred Object
1. 简介和创建
详见API:http://api.jquery.com/jQuery.Deferred/。jQuery Deferred是”based onCommonJS Promises/A design”,并不完全等同于ES6的Promise,或者浏览器/JS引擎实现的原生Promise,或是各类Promise库。
jQuery.Deferred()工厂函数创建一个新的deferred object并且返回这个deferred:
jQuery.extend({ Deferred: function (func) { var deferred = {}; // ... // 实现deferred object的对象方法 // ... return deferred; } })
2. deferred与闭包
由于deferred的每个对象方法method都访问了外部函数jQuery.Deferred()中的局部变量,因此jQuery.Deferred()在执行完毕后,其活动对象activation object不会被销毁,而是被保存在deferred的每个method的[[Scope]]属性中(仅保存指针)。这样deferred的method在执行时就可以通过作用域链scope chain访问到deferred的“私有变量”(参见JavaScript高级程序设计第三版7.4章)。简而言之,deferred的每个method都是jQuery.Deferred()的内部函数。
注意这里的“私有变量”不是静态的,即每次通过调用jQuery.Deferred()得到的deferred都有自己的一份“私有变量”。
var version = "3.1.1", // Define a local copy of jQuery jQuery = function (selector, context) {...},
注2:这是在jQuery“块级作用域”里,通过下面的语句expose到全局环境下的,注意注1和注2中的jQuery作用域不同,虽然它们有着同样的名字并指向同样的对象:
window.jQuery = window.$ = jQuery;
注3:jQuery.Deferred()返回的deferred object本身是jQuery.Deferred()的一个局部变量。
注4:deferred.promise()返回这个promise object。
3. deferred的私有变量
3.1. state
- 可取三种值”pending”,”resolved”,”rejected”之一,分别对应Spec里的 pending,fulfilled, or rejected;
- 可以通过.state()方法读取;
- 初始状态是”pendinig”。
3.2 promise
可以通过.promise()方法读取。和deferred一样是jQuery.Deferred()的局部变量:var promise = { ... promise: function (obj) { return obj != null ? jQuery.extend(obj, promise) : promise; } }, deferred = {}; ... // 向deferred添加resolve,reject,notify,resolveWith,rejectWith和notifyWith方法 // Make the deferred a promise promise.promise(deferred);
从上面jQuery.Deferred()的代码可以看出,deferred对象copy了promise所有的方法;deferred和promise的方法指向相同的函数实例,因而deferred和deferred.promise()拥有同一份“私有变量”。
promise没有可以改变state的方法,即promise没有.resolve()/.resolveWith()/.reject()/.rejectWith()/.notify()/.notifyWith()方法。这样返回deferred.promise()给其它代码就可以确保其它代码不会改变deferred的状态或触发回调函数的执行。
3.3 tuples
tuples数组存放了6个callback list object,为讨论方便,我们命名
progress_callbacks = tuples[0][2], progress_handlers = tuples[0][3]
fulfilled_callbacks = tuples[1][2], fulfilled_handlers = tuples[1][3]
rejected_callbacks = tuples[2][2], rejected_handlers = tuples[2][3]
var tuples = [ // action, add listener, callbacks, // ... .then handlers, argument index, [final state] ["notify", "progress", jQuery.Callbacks("memory"), jQuery.Callbacks("memory"), 2], ["resolve", "done", jQuery.Callbacks("once memory"), jQuery.Callbacks("once memory"), 0, "resolved"], ["reject", "fail", jQuery.Callbacks("once memory"), jQuery.Callbacks("once memory"), 1, "rejected"] ],
3.3.1 callback list
以fulfilled_callbacks即tuples[1][2]为例,它是由jQuery.Callbacks(“once memory”)创建的一个callback list,这个callbacklist的.add()方法把回调函数加入到list中,而.fireWith()方法将导致list里的所有回调函数以类似于”先进先出”的顺序执行。
3.3.2 “once” flag
fulfilled_callbacks创建时带有两个flag:”once”和”memory”。“once”表示这个callback list只能通过.fireWith()或.fire()的调用被fire一次,以后再次调用这个callback list的.fireWith()或.fire()没有任何效果。
注意progress_callbacks和progress_handlers创建时没有”once”这个flag,也就是说这两个callback list可以被多次fire,每次fire时list里的所有回调函数顺序执行。
3.3.3 “memory” flag
callback list在fire时的context和arguments将被“记忆”下来,这样在.fireWith()之后调用.add()的话,新加入的回调函数将马上用“记住”的context和arguments执行。测试如下:
fulfilled_callbacks = jQuery.Callbacks("once memory"); fulfilled_callbacks.add(fn1); fulfilled_callbacks.add(fn2); fulfilled_callbacks.fireWith(context, args); // fn1先执行,即fn1.apply(context,args);然后fn2执行fn2.apply(context,args) fulfilled_callbacks.fireWith(context, args); // 没有任何效果 fulfilled_callbacks.add(fn3); // fn3马上执行,即fn3.apply(context, args)
3.4. 对象方法与私有变量
Deferred的对象方法 |
这个方法会调用 |
对状态的影响 |
效果 |
.done() |
fulfilled_callbacks.add() |
不改变state |
把回调函数加入到fulfilled_callbacks中 |
.resolve()/.resolveWith() |
fulfilled_callbacks.fireWith() |
state = “resovled” |
fulfilled_callbacks中的所有回调函数被执行注1 fulfilled_handlers中的所有回调函数被执行 |
.fail() |
rejected_callbacks.add() |
不改变state |
把回调函数加入到rejected_callbacks中 |
.reject()/.rejectWith() |
rejected_callbacks.fireWith() |
state = “rejected” |
rejected_callbacks中的所有回调函数被执行注1 rejected_handlers中的所有回调函数被执行 |
.progress() |
progress_callbacks.add() |
不改变state |
把回调函数加入到progress_callbacks中 |
.notify()/.notifyWith() |
progress_callbacks.fireWith() |
不改变state |
progress_callbacks中的所有回调函数被执行 progress_handlers中的所有回调函数被执行 |
.then()/.catch() |
fulfilled_handlers.add() rejected_handlers.add() progress_handlers.add() |
不改变state |
把回调函数加入到fulfilled_handlers中 把回调函数加入到rejected_handlers中 把回调函数加入到progress_handlers中 |
注1:这两个方法如果重复执行的话,只有第一次的调用会有效果,原因见3.3.2。
4. 链式调用
除了.state()和.promise()外,deferred的其它方法均返回一个deferred object,这样deferred就可以支持链式调用,例如.always():
always: function () { deferred.done(arguments).fail(arguments); return this; },
调用.always()方法相当于同时向fulfilled_callbacks和rejected_callbacks中添加了一个同样的回调函数,这样无论这个deferred是被.resolve()/.resolveWith()还是.reject()/.rejectWith(),这个回调函数always将被执行。
需要注意的是大多数方法均返回this指针,也就是方法在哪个deferred上被调用,就返回哪个deferred。而.then()和.catch()方法返回的是一个新的deferred的promise。
顺便一提,deferred.catch(fn)就是deferred.then(null, fn),所以下面就不单独讨论.catch()方法了。
二.Control Flow
1. 同步执行流程
这里的同步执行流程指的是在同一个event loop里被顺序执行的代码。由于是在一个event loop里单线程运行,这些代码是同步执行的。例如deferred.resolve()/.resolveWith()被调用时,代码总是按照下图中箭头指定的顺序执行:
注1:也就是说,在deferred.resolve()/.resolveWith()之后,再去调用deferred.reject()/.rejectWith()将没有任何效果。反之亦然。
注2:如果.notify()/.notifyWith()被调用过,那么.resolve()/.resolveWith()调用时不会disable掉progress_callbacks.add(),这样仍然可以通过progress()方法加入progress的回调函数,而且这样加入的回调函数会被立即执行。即:
dfd1 = jQuery.Deferred(); dfd1.progress(function () { console.log("progress1") }); dfd1.notify(); // console log "progress1" dfd1.resolve(); dfd1.progress(function () { // console log "progress2" immediately, i.e. before dfd1.progress() returns console.log("progress2") });
当然如果.notify()/.notifyWith()没有被调用过,那么.resolve()/.resolveWith()调用后就无法通过.progress()方法加入progress的回调函数了。
2. .then()
2.1 .then()同步执行流程
jQuery.Deferred()调用时可以带一个参数,这个参数指向一个函数func,在jQuery.Deferred()最后返回deferred之前会调用这个函数func。
Deferred: function (func) { … if (func) { func.call(deferred, deferred); } // All done! return deferred; },
.then()在最终返回新的deferredobject(其实是promise)之前,就调用了一个函数func:
then: function (onFulfilled, onRejected, onProgress) { … return jQuery.Deferred(func).promises(); }
.then()方法的同步执行流程如下:
用文字描述的话,deferred.then(onFulfilled)方法被调用时主要完成了两件“任务”:
a. 把“包裹”了真正的回调函数onFulfilled的一个函数加入了deferred的“私有变量”fulfilled_handlers当中;
b. 产生了一个新的deferred object即newDefer,并最终返回了newDefer.promise()。
当然这只是逻辑上的划分,实际运行时.then()是同步执行的:“任务”b的前半段先执行(得到了newDefer),接下来“任务”a执行(需要newDefer作为实参),最后“任务”b的后半段执行,就如上图所示。
2.2 .then()运行时加入到fulfilled_handlers中的函数
在上图右侧代码部分,tuples[1][3]就是fulfilled_handlers,它的.add()方法将这个方法的参数加入到fulfilled_handlers中,也就是把执行resolve()函数得到的返回值加入到fulfilled_handlers中。而resolve()函数返回一个匿名的内部函数,所以,加入到fulfilled_handlers中的函数是执行resolve()函数返回的(resolve()函数的)内部函数。
function resolve(depth, deferred, handler, special) { return function () { … }; }
请注意这个resolve()函数本身是.then()方法的内部函数,并不是.resolve()方法。
换句话说,.then()运行后,deferred的”私有变量“fulfilled_handlers的“私有变量”list数组的第一个元素list[0]就指向上面这个resolve()返回的匿名函数。这个匿名函数的定义见下一节。
3. 异步执行
3.1 异步的触发
deferred.resolve()/resolveWith()执行时,会调用fulfilled_handlers.fire(),从而运行已加入到fulfilled_handlers中的函数。从上一节可知,此时运行的就是resolve()的内部匿名函数,如下:
function () { var that = this, args = arguments, mightThrow = function () {…}, // Only normal processors (resolve) catch and reject exceptions process = special ? mightThrow : function () { try { mightThrow(); } catch (e) {…} } }; // Support: Promises/A+ section 2.3.3.3.1 // https://promisesaplus.com/#point-57 // Re-resolve promises immediately to dodge false rejection from // subsequent errors if (depth) { process(); } else { … window.setTimeout(process); } }; }
这个函数定义了两个(对于它而言的)内部函数process()和mightThrow(),并在最后调用了window.setTimeout(),这样process()作为定时器的回调函数被异步执行。process()最早也要在下一个event loop才会得到机会运行,而且开始它运行前execution stack是空的,this变量指向window(sloppy mode)或undefined(strict mode),这样process()只有通过闭包才能访问到需要的变量,详见下图。
3.2 异步执行时的作用域链
3.3 process()的执行
3.3.1 Evaluation of handler
deferred.resolve()/resolveWith()执行时,最终会导致process()被异步执行。
procss()首先运行先前.then()调用中传入的handler即上图中的onFulfilled,返回值赋给returned;
returned = handler.apply(that, args);
这里handler是.then()调用中传入的onFulfilled,that是.resolveWith()时传入的context,args是.resolveWith()时传入的args,参考上图。
3.3.2 Promise Resolution Procedure
3.3.2.1 Evalution of handler returns non-thenable
process()会执行下面的语句来完成状态传递:
deferred.resolveWith(that, args);
这里deferred其实是最开始调用.then()所产生的newDefer,that是调用.resolveWith()时传入的context,args是evaluation of handler的结果即returned,参考上图中的作用域链。
例如下面的代码就会走这种分支执行:
deferred = jQuery.Deferred(); promise = deferred.then(function (state) { // state is 1 when this handler is called return state + 1; // returns new state 2 }); deferred.resolve(1); // process() runs async promise.done(function (newState) { // newState is the value promise is resolved to, i.e. 2 in this case console.log(newState) });
3.3.2.2 Evaluation of handler returns thenable
这种情况下evalutation of handler返回了一个thenable,也就是有着then方法的对象returned,process()会执行下面的语句:
then = returned.then; then.call( returned, resolve(maxDepth, deferred, Identity, special), // Identity_wrapper_handler resolve(maxDepth, deferred, Thrower, special), resolve(maxDepth, deferred, Identity, deferred.notifyWith) );
这里的deferred是最初的.then()调用所产生的newDefer。另外为方便起见,我们把上面这个call()调用中的第二个参数叫做Identity_wrapper_handler。接下去的流程如下。
3.3.2.2.1 当这个thenable即returned被resolve的时候,process()将被异步调用,这是整个流程中process()第二次运行。这次被evaluate的handler是Identity_wrapper_handler。
3.3.2.2.2 Identity_wrapper_handler是调用resolve(maxDepth, deferred, Identity, special)返回的函数,这里maxDepth=1,deferred就是最初的.then()调用所产生的newDefer,可参考上图中的作用域链。运行identity_wrapper_handler会导致process()再次被运行。注意在Identity_wrapper_handler中,process()函数是立即运行而不是通过window.setTimeout(process)异步运行的。
3.3.2.2.3 process()在整个流程中第三次运行,这次被evalutate的handler是Identity函数。Identity函数定义如下:
function Identity(v) { return v; }
Identity函数运行时的context是returned被resolve时的context,参数是returned被resolve时的值。这样Identity函数运行完毕之后,流程又走回到了3.3.2 Promise Resolution Procedure,这时evalution of handler返回的就是上一个thenalbe被resolve时的值。请注意在这个第三次运行的process()中,闭包中存放的deferred引用指向最初的deferred.then()所产生的newDefer,这样就保证了变化的状态能被传递到正确的deferred object上。
对照规范https://promisesaplus.com/来看,这就是规范中的2.3所描述的从[[Resolve]](promise,x)
到[[Resolve]](promise,y)的过程。
例如下面的代码就会走这个小节即3.3.2.2的流程:
deferred = jQuery.Deferred(); anotherDeferred = jQuery.Deferred(); fulfillment_handler = function () { return anotherDeferred.promise(); // a thenable is returned }; newDefer = deferred.then(fulfillment_handler); deferred.resolveWith(context1, [1]); // process() runs async anotherDeferred.resolveWith(context2, [2]); // another process() runs async, and during the execution of this process() a third process() will run synchronously
在上面代码运行的整个流程中,process()总共运行了三次,每次运行时的部分作用域如下:
scope chain | 作用域 | 变量 | process()第一次运行时 | process()第二次运行时 | process()第三次运行时 |
[4] | jQuery.Deferred activation object | deferred | deferred** | anotherDeferred | deferred** |
[3] | .then activation object | maxDepth | 0* | 0 | 1* |
[2] | resolve activation object | depth | 0 | 0 | 1 |
deferred | newDefer | anotherDeferred.promise().then()所生成并返回的一个deferred object | newDefer | ||
handler | fulfillment_handler | Identity_wrapper_handler | Identity | ||
[1] | anonymous activation object | that | context1 | context2 | context2 |
args | [1] | [2] | [2] |
* process()第一次和第三次运行时,scope chain[3]其实指向同一个activation object,只不过里面的变量maxDepth从0变成了1。
** 这两个scope chain指针也指向同一个activation object,因为scope chain[3]相同。
另外每次process()运行时,scope chain[5]指向同一个jQuery Closure activation object,scope chain[6]指向同一个Global variable object。
3.3.3 Exceptions
process()在运行handler(evalution of handler)或者调用thenable对象的then方法时,如果发生了异常或者异常被抛出,process()会catch exception并调用newDefer的.rejectWith()方法,这样newDefer就会变成rejected状态,确保了exception也会被传递下去。
3.3.4 Thenable self-resolution
下面的代码会导致newDefer要进入resolved状态就必须等待自己被resolve,这是一个逻辑上的死循环,相当于[[Resolve]](promise,promise)
。
deferred = jQuery.Deferred(); newPromise = deferred.then(function () { return newPromise; }); deferred.resolve(1); // newPromise is never resolved, and jQuery.Deferred exception will be thrown
jQuery对于这种情况在deferred.resolve()时会抛出异常jQuery.Deferred exception: Thenable self-resolution。
三.Deferred的应用
jQuery中ready方法还有ajax等等都用到了deferred object。
1. .ready()
使用jQuery时,类似$( handler )的调用会调用下面的.ready()方法把handler加入到一个名为readyList的deferred object中。
var readyList = jQuery.Deferred(); jQuery.fn.ready = function (fn) { readyList .then(fn) .catch(function (error) { jQuery.readyException(error); }); return this; };
当document的"DOMContentLoaded"事件或者window的"load"事件发生时,jQuery注册的回调函数运行,最终会resolve readyList:
readyList.resolveWith(document, [jQuery]);
这样readyList上的handler就会运行。一些细节的讨论:
- ready handler运行时的context是document,参数是jQuery,这样可以把ready handler写成function ( $ ) { ... }来安全地使用$代替jQuery。
- 如果jQuery的js文件是在"DOMContentLoaded"或”load"事件之后动态加载的,也就是说jQuery注册的回调函数错过了这两个事件怎么办呢?jQuery提供了一个工具方法jQuery.ready(),调用这个方法就可以resolve readyList。实际上jQuery注册的事件回调函数也是调用jQuery.ready()来resolve readyList的。
- .ready()中之所以用.then()而不用.done()把handler加入到readList,是因为.then()不仅可以传递状态,而且handler运行中的exception会被catch,通过rejected deferred/promise传给后面的.catch()。.catch()调用了jQuery.readyException()异步抛出了handler抛出的error。也就是说,如果用户编写的ready handler在运行时发生了错误,那么jQuery将异步抛出exception,这样不会影响接下去其它ready handler或代码同步运行。
以上是.ready()的实现,对于jQuery的使用者来说,一般只要直接写$( handler )就可以了,简洁方便但又不失灵活。这也是我认为jQuery最突出的优点。随着ECMA Script的发展和浏览器的进化,十年前jQuery的其它优势比如浏览器的兼容,Sizzle引擎等等已经不那么明显了,但是它的设计和实现细节一直值得学习。
jQuery源码学习:Deferred Object