读Zepto源码之Callbacks模块

pxrr2646 7年前
   <p>Callbacks 模块并不是必备的模块,其作用是管理回调函数,为 Defferred 模块提供支持,Defferred 模块又为 Ajax 模块的 promise 风格提供支持,接下来很快就会分析到 Ajax模块,在此之前,先看 Callbacks 模块和 Defferred 模块的实现。</p>    <h2>源码版本</h2>    <p>本文阅读的源码为 <a href="/misc/goto?guid=4959750871803332655" rel="nofollow,noindex">zepto1.2.0</a></p>    <h2>整体结构</h2>    <p>将 Callbacks 模块的代码精简后,得到的结构如下:</p>    <pre>  <code class="language-javascript">;(function($){    $.Callbacks = function(options) {      ...      Callbacks = {        ...      }      return Callbacks    }  })(Zepto)</code></pre>    <p>其实就是向 zepto 对象上,添加了一个 Callbacks 函数,这个是一个工厂函数,调用这个函数返回的是一个对象,对象内部包含了一系列的方法。</p>    <p>options 参数为一个对象,在源码的内部,作者已经注释了各个键值的含义。</p>    <pre>  <code class="language-javascript">// Option flags:    //   - once: Callbacks fired at most one time.    //   - memory: Remember the most recent context and arguments    //   - stopOnFalse: Cease iterating over callback list    //   - unique: Permit adding at most one instance of the same callback  once: 回调至多只能触发一次  memory: 记下最近一次触发的上下文及参数列表,再添加新回调的时候都立刻用这个上下文及参数立即执行  stopOnFalse: 如果队列中有回调返回 `false`,立即中止后续回调的执行  unique: 同一个回调只能添加一次</code></pre>    <h2>全局变量</h2>    <pre>  <code class="language-javascript">options = $.extend({}, options)    var memory, // Last fire value (for non-forgettable lists)      fired,  // Flag to know if list was already fired      firing, // Flag to know if list is currently firing      firingStart, // First callback to fire (used internally by add and fireWith)      firingLength, // End of the loop when firing      firingIndex, // Index of currently firing callback (modified by remove if needed)      list = [], // Actual callback list      stack = !options.once && [], // Stack of fire calls for repeatable lists</code></pre>    <ul>     <li>options : 构造函数的配置,默认为空对象</li>     <li>list : 回调函数列表</li>     <li>stack : 列表可以重复触发时,用来缓存触发过程中未执行的任务参数,如果列表只能触发一次, stack 永远为 false</li>     <li>memory : 记忆模式下,会记住上一次触发的上下文及参数</li>     <li>fired : 回调函数列表已经触发过</li>     <li>firing : 回调函数列表正在触发</li>     <li>firingStart : 回调任务的开始位置</li>     <li>firingIndex : 当前回调任务的索引</li>     <li>firingLength :回调任务的长度</li>    </ul>    <h2>基础用法</h2>    <p>我用 jQuery 和 Zepto 的时间比较短,之前也没有直接用过 Callbacks 模块,单纯看代码不易理解它是怎样工作的,在分析之前,先看一下简单的 API 调用,可能会有助于理解。</p>    <pre>  <code class="language-javascript">var callbacks = $.Callbacks({memory: true})  var a = function(a) {    console.log('a ' + a)  }  var b = function(b) {    console.log('b ' + b)  }  var c = function(c) {    console.log('c ' + c)  }  callbacks.add(a).add(b).add(c)  // 向队列 list 中添加了三个回调  callbacks.remove(c) // 删除 c  callbacks.fire('fire')   // 到这步输出了 `a fire` `b fire` 没有输出 `c fire`  callbacks.lock()  callbacks.fire('fire after lock')  // 到这步没有任何输出  // 继续向队列添加回调,注意 `Callbacks` 的参数为 `memory: true`  callbacks.add(function(d) {      console.log('after lock')  })  // 输出 `after lock`  callbacks.disable()  callbacks.add(function(e) {    console.log('after disable')  })   // 没有任何输出</code></pre>    <p>上面的例子只是简单的调用,也有了注释,下面开始分析 API</p>    <h2>内部方法</h2>    <h3>fire</h3>    <pre>  <code class="language-javascript">fire = function(data) {    memory = options.memory && data    fired = true    firingIndex = firingStart || 0    firingStart = 0    firingLength = list.length    firing = true    for ( ; list && firingIndex < firingLength ; ++firingIndex ) {      if (list[firingIndex].apply(data[0], data[1]) === false && options.stopOnFalse) {        memory = false        break      }    }    firing = false    if (list) {      if (stack) stack.length && fire(stack.shift())      else if (memory) list.length = 0      else Callbacks.disable()        }  }</code></pre>    <p>Callbacks 模块只有一个内部方法 fire ,用来触发 list 中的回调执行,这个方法是 Callbacks 模块的核心。</p>    <p>变量初始化</p>    <pre>  <code class="language-javascript">memory = options.memory && data  fired = true  firingIndex = firingStart || 0  firingStart = 0  firingLength = list.length  firing = true</code></pre>    <p>fire 只接收一个参数 data ,这个内部方法 fire 跟我们调用 API 所接收的参数不太一样,这个 data 是一个数组,数组里面只有两项,第一项是上下文对象,第二项是回调函数的参数数组。</p>    <p>如果 options.memory 为 true ,则将 data ,也即上下文对象和参数保存下来。</p>    <p>将 list 是否已经触发过的状态 fired 设置为 true 。</p>    <p>将当前回调任务的索引值 firingIndex 指向回调任务的开始位置 firingStart 或者回调列表的开始位置。</p>    <p>将回调列表的开始位置 firingStart 设置为回调列表的开始位置。</p>    <p>将回调任务的长度 firingLength 设置为回调列表的长度。</p>    <p>将回调的开始状态 firing 设置为 true</p>    <p>执行回调</p>    <pre>  <code class="language-javascript">for ( ; list && firingIndex < firingLength ; ++firingIndex ) {    if (list[firingIndex].apply(data[0], data[1]) === false && options.stopOnFalse) {      memory = false      break    }  }  firing = false</code></pre>    <p>执行回调的整体逻辑是遍历回调列表,逐个执行回调。</p>    <p>循环的条件是,列表存在,并且当前回调任务的索引值 firingIndex 要比回调任务的长度要小,这个很容易理解,当前的索引值都超出了任务的长度,就找不到任务执行了。</p>    <p>list[firingIndex].apply(data[0], data[1]) 就是从回调列表中找到对应的任务,绑定上下文对象,和传入对应的参数,执行任务。</p>    <p>如果回调执行后显式返回 false , 并且 options.stopOnFalse 设置为 true ,则中止后续任务的执行,并且清空 memory 的缓存。</p>    <p>回调任务执行完毕后,将 firing 设置为 false ,表示当前没有正在执行的任务。</p>    <p>检测未执行的回调及清理工作</p>    <pre>  <code class="language-javascript">if (list) {    if (stack) stack.length && fire(stack.shift())    else if (memory) list.length = 0    else Callbacks.disable()  }</code></pre>    <p>列表任务执行完毕后,先检查 stack 中是否有没有执行的任务,如果有,则将任务参数取出,调用 fire 函数执行。后面会看到, stack 储存的任务是 push 进去的,用 shift 取出,表明任务执行的顺序是先进先出。</p>    <p>memory 存在,则清空回调列表,用 list.length = 0 是清空列表的一个方法。在全局参数中,可以看到, stack 为 false ,只有一种情况,就是 options.once 为 true 的时候,表示任务只能执行一次,所以要将列表清空。而 memory 为 true ,表示后面添加的任务还可以执行,所以还必须保持 list 容器的存在,以便后续任务的添加和执行。</p>    <p>其他情况直接调用 Callbacks.disable() 方法,禁用所有回调任务的添加和执行。</p>    <h2>.add()</h2>    <pre>  <code class="language-javascript">add: function() {    if (list) {      var start = list.length,          add = function(args) {            $.each(args, function(_, arg){              if (typeof arg === "function") {                if (!options.unique || !Callbacks.has(arg)) list.push(arg)                  }              else if (arg && arg.length && typeof arg !== 'string') add(arg)                })          }      add(arguments)      if (firing) firingLength = list.length      else if (memory) {        firingStart = start        fire(memory)      }    }    return this  },</code></pre>    <p>start 为原来回调列表的长度。保存起来,是为了后面修正回调任务的开始位置时用。</p>    <h3>内部方法add</h3>    <pre>  <code class="language-javascript">add = function(args) {    $.each(args, function(_, arg){      if (typeof arg === "function") {        if (!options.unique || !Callbacks.has(arg)) list.push(arg)          }      else if (arg && arg.length && typeof arg !== 'string') add(arg)        })  }</code></pre>    <p>add 方法的作用是将回调函数 push 进回调列表中。参数 arguments 为数组或者伪数组。</p>    <p>用 $.each 方法来遍历 args ,得到数组项 arg ,如果 arg 为 function 类型,则进行下一个判断。</p>    <p>在下一个判断中,如果 options.unique 不为 true ,即允许重复的回调函数,或者原来的列表中不存在该回调函数,则将回调函数存入回调列表中。</p>    <p>如果 arg 为数组或伪数组(通过 arg.length 是否存在判断,并且排除掉 string 的情况),再次调用 add 函数分解。</p>    <h3>修正回调任务控制变量</h3>    <pre>  <code class="language-javascript">add(arguments)  if (firing) firingLength = list.length  else if (memory) {    firingStart = start    fire(memory)  }</code></pre>    <p>调用 add 方法,向列表中添加回调函数。</p>    <p>如果回调任务正在执行中,则修正回调任务的长度 firingLength 为当前任务列表的长度,以便后续添加的回调函数可以执行。</p>    <p>否则,如果为 memory 模式,则将执行回调任务的开始位置设置为 start ,即原来列表的最后一位的下一位,也就是新添加进列表的第一位,然后调用 fire ,以缓存的上下文及参数 memory 作为 fire 的参数,立即执行新添加的回调函数。</p>    <h2>.remove()</h2>    <pre>  <code class="language-javascript">remove: function() {    if (list) {      $.each(arguments, function(_, arg){        var index        while ((index = $.inArray(arg, list, index)) > -1) {          list.splice(index, 1)          // Handle firing indexes          if (firing) {            if (index <= firingLength) --firingLength            if (index <= firingIndex) --firingIndex              }        }      })    }    return this  },</code></pre>    <p>删除列表中指定的回调。</p>    <h3>删除回调函数</h3>    <p>用 each 遍历参数列表,在 each 遍历里再有一层 while 循环,循环的终止条件如下:</p>    <pre>  <code class="language-javascript">(index = $.inArray(arg, list, index)) > -1</code></pre>    <p>$.inArray() 最终返回的是数组项在数组中的索引值,如果不在数组中,则返回 -1 ,所以这个判断是确定回调函数存在于列表中。关于 $.inArray 的分析,见《 <a href="/misc/goto?guid=4959750871895944846" rel="nofollow,noindex">读zepto源码之工具函数</a> 》。</p>    <p>然后调用 splice 删除 list 中对应索引值的数组项,用 while 循环是确保列表中有重复的回调函数都会被删除掉。</p>    <h3>修正回调任务控制变量</h3>    <pre>  <code class="language-javascript">if (firing) {    if (index <= firingLength) --firingLength    if (index <= firingIndex) --firingIndex  }</code></pre>    <p>如果回调任务正在执行中,因为回调列表的长度已经有了变化,需要修正回调任务的控制参数。</p>    <p>如果 index <= firingLength ,即回调函数在当前的回调任务中,将回调任务数减少 1 。</p>    <p>如果 index <= firingIndex ,即在正在执行的回调函数前,将正在执行函数的索引值减少 1 。</p>    <p>这样做是防止回调函数执行到最后时,没有找到对应的任务执行。</p>    <h2>.fireWith</h2>    <pre>  <code class="language-javascript">fireWith: function(context, args) {    if (list && (!fired || stack)) {      args = args || []      args = [context, args.slice ? args.slice() : args]      if (firing) stack.push(args)      else fire(args)        }    return this  },</code></pre>    <p>以指定回调函数的上下文的方式来触发回调函数。</p>    <p>fireWith 接收两个参数,第一个参数 context 为上下文对象,第二个 args 为参数列表。</p>    <p>fireWith 后续执行的条件是列表存在并且回调列表没有执行过或者 stack 存在(可为空数组),这个要注意,后面讲 disable 方法和 lock 方法区别的时候,这是一个很重要的判断条件。</p>    <pre>  <code class="language-javascript">args = args || []  args = [context, args.slice ? args.slice() : args]</code></pre>    <p>先将 args 不存在时,初始化为数组。</p>    <p>再重新组合成新的变量 args ,这个变量的第一项为上下文对象 context ,第二项为参数列表,调用 args.slice 是对数组进行拷贝,因为 memory 会储存上一次执行的上下文对象及参数,应该是怕外部对引用的更改的影响。</p>    <pre>  <code class="language-javascript">if (firing) stack.push(args)  else fire(args)</code></pre>    <p>如果回调正处在触发的状态,则将上下文对象和参数先储存在 stack 中,从内部函数 fire 的分析中可以得知,回调函数执行完毕后,会从 stack 中将 args 取出,再触发 fire 。</p>    <p>否则,触发 fire ,执行回调函数列表中的回调函数。</p>    <p>add 和 remove 都要判断 firing 的状态,来修正回调任务控制变量, fire 方法也要判断 firing ,来判断是否需要将 args 存入 stack 中,但是 javascript 是单线程的,照理应该不会出现在触发的同时 add 或者 remove 或者再调用 fire 的情况。</p>    <h2>.fire()</h2>    <pre>  <code class="language-javascript">fire: function() {    return Callbacks.fireWith(this, arguments)  },</code></pre>    <p>fire 方法,用得最多,但是却非常简单,调用的是 fireWidth 方法,上下文对象是 this 。</p>    <h2>.has()</h2>    <pre>  <code class="language-javascript">has: function(fn) {    return !!(list && (fn ? $.inArray(fn, list) > -1 : list.length))  },</code></pre>    <p>has 有两个作用,如果有传参时,用来查测所传入的 fn 是否存在于回调列表中,如果没有传参时,用来检测回调列表中是否已经有了回调函数。</p>    <pre>  <code class="language-javascript">fn ? $.inArray(fn, list) > -1 : list.length</code></pre>    <p>这个三元表达式前面的是判断指定的 fn 是否存在于回调函数列表中,后面的,如果 list.length 大于 0 ,则回调列表已经存入了回调函数。</p>    <h2>.empty()</h2>    <pre>  <code class="language-javascript">empty: function() {    firingLength = list.length = 0    return this  },</code></pre>    <p>empty 的作用是清空回调函数列表和正在执行的任务,但是 list 还存在,还可以向 list 中继续添加回调函数。</p>    <h2>.disable()</h2>    <pre>  <code class="language-javascript">disable: function() {    list = stack = memory = undefined    return this  },</code></pre>    <p>disable 是禁用回调函数,实质是将回调函数列表置为 undefined ,同时也将 stack 和 memory 置为 undefined ,调用 disable 后, add 、 remove 、 fire 、 fireWith 等方法不再生效,这些方法的首要条件是 list 存在。</p>    <h2>.disabled()</h2>    <pre>  <code class="language-javascript">disabled: function() {    return !list  },</code></pre>    <p>回调是否已经被禁止,其实就是检测 list 是否存在。</p>    <h2>.lock()</h2>    <pre>  <code class="language-javascript">lock: function() {    stack = undefined    if (!memory) Callbacks.disable()    return this  },</code></pre>    <p>锁定回调列表,其实是禁止 fire 和 fireWith 的执行。</p>    <p>其实是将 stack 设置为 undefined , memory 不存在时,调用的是 disable 方法,将整个列表清空。效果等同于禁用回调函数。 fire 和 add 方法都不能再执行。</p>    <h3>.lock() 和 .disable() 的区别</h3>    <p>为什么 memory 存在时, stack 为 undefined 就可以将列表的 fire 和 fireWith 禁用掉呢?在上文的 fireWith 中,我特别提到了 !fired || stack 这个判断条件。在 stack 为 undefined 时, fireWith 的执行条件看 fired 这个条件。如果回调列表已经执行过, fired 为 true , fireWith 不会再执行。如果回调列表没有执行过, memory 为 undefined ,会调用 disable 方法禁用列表, fireWith 也不能执行。</p>    <p>所以, disable 和 lock 的区别主要是在 memory 模式下,回调函数触发过后, lock 还可以调用 add 方法,向回调列表中添加回调函数,添加完毕后会立刻用 memory 的上下文和参数触发回调函数。</p>    <h2>.locked()</h2>    <pre>  <code class="language-javascript">locked: function() {    return !stack  },</code></pre>    <p>回调列表是否被锁定。</p>    <p>其实就是检测 stack 是否存在。</p>    <h2>.fired()</h2>    <pre>  <code class="language-javascript">fired: function() {    return !!fired  }</code></pre>    <p>回调列表是否已经被触发过。</p>    <p>回调列表触发一次后 fired 就会变为 true ,用 !! 的目的是将 undefined 转换为 false 返回。</p>    <p> </p>    <p>来自:http://div.io/topic/2017</p>    <p> </p>