說(shuō)來(lái)慚愧，之前沒讀過(guò)什么源碼，今天嘗試研究下async框架的源碼，就從https://github.com/bsspirit/async_demo這個(gè)地方拉了一個(gè)async使用的demo來(lái)入手，好，一個(gè)一個(gè)js，一個(gè)一個(gè)函數(shù)來(lái)了解！

?

apply.js

async.apply是給一個(gè)函數(shù)預(yù)綁定多個(gè)參數(shù)并生成一個(gè)可直接調(diào)用的新函數(shù)，demo中所給出的例子是

1 function inc(a,b,callback,timeout){　　//先定義一個(gè)加法函數(shù) 2 var timeout = timeout || 200; 3 t.wait(200); 4 setTimeout(function() { 5 callback(null, a+b); 6 }, timeout); 7 } 8 var fn = async.apply(inc, 1, 2);　　//調(diào)用apply函數(shù)且賦予其部分參數(shù) 9 fn(function(err, n){ 10 log('1.2 inc: ' + n); 11 }，500);　　　　　　　　　　　　　　　　 //調(diào)用apply返回的函數(shù)并補(bǔ)齊所需參數(shù)，即相當(dāng)于調(diào)用inc函數(shù)

由此找到async.js中的apply函數(shù)

1 async.apply = _restParam(function (fn, args) { 2 return _restParam(function (callArgs) {　　//返回一個(gè)函數(shù)并帶有調(diào)用該函數(shù)時(shí)所需參數(shù) 3 return fn.apply( 4 null, args.concat(callArgs)　　//將調(diào)用所帶參數(shù)與已有參數(shù)合并，接著傳給自定義的函數(shù)（即之前的inc函數(shù)） 5 ); 6 }); 7 });

從以上內(nèi)容可以看出，apply的實(shí)現(xiàn)原理就是返回一個(gè)帶已有參數(shù)的函數(shù)，然后在調(diào)用該函數(shù)的時(shí)候再傳入其余參數(shù)，最后去調(diào)用自定義的函數(shù)

?

?applyEach.js

async.applyEach可以實(shí)現(xiàn)給一數(shù)組中每個(gè)函數(shù)傳相同參數(shù)，通過(guò)callback返回來(lái)遍歷所有函數(shù)的執(zhí)行，eachOf函數(shù)是實(shí)現(xiàn)applyEach的一個(gè)函數(shù)，以下是源碼：

1 async.forEachOf = 2 async.eachOf = function (object, iterator, callback) { 3 callback = _once(callback || noop); 4 object = object || []; 5 6 var iter = _keyIterator(object); 7 var key, completed = 0; 8 9 while ((key = iter()) != null) { 10 completed += 1;　　　　　　　　//這里用completed累加來(lái)計(jì)數(shù)數(shù)組中函數(shù)的個(gè)數(shù) 11 iterator(object[key], key, only_once(done)); 12 } 13 14 if (completed === 0) callback(null); 15 16 function done(err) { 17 completed--;　　　　　　　　//因?yàn)槭钱惒?#xff0c;所以只能通過(guò)計(jì)數(shù)的方法來(lái)檢測(cè)數(shù)組中的函數(shù)是否執(zhí)行結(jié)束，直至completed重新變回0即說(shuō)明全部執(zhí)行結(jié)束 18 console.log(completed); 19 if (err) { 20 callback(err); 21 } 22 // Check key is null in case iterator isn't exhausted 23 // and done resolved synchronously. 24 else if (key === null && completed <= 0) { 25 callback(null); 26 } 27 } 28 };

async.applyEachSeries與前者不同的是用于實(shí)現(xiàn)數(shù)組的函數(shù)同步執(zhí)行，研究其源碼的時(shí)候遇到比較難理解的是eachOfSeries的實(shí)現(xiàn)，源碼：

1 async.forEachOfSeries = 2 async.eachOfSeries = function (obj, iterator, callback) { 3 callback = _once(callback || noop); 4 obj = obj || []; 5 var nextKey = _keyIterator(obj); 6 var key = nextKey(); 7 function iterate() {　　 8 var sync = true; 9 if (key === null) { 10 return callback(null); 11 } 12 iterator(obj[key], key, only_once(function (err) {　　//這里將函數(shù)數(shù)組中一個(gè)一個(gè)取出執(zhí)行 13 if (err) { 14 callback(err); 15 } 16 else { 17 key = nextKey(); 18 if (key === null) { 19 return callback(null); 20 } else { 21 if (sync) { 22 async.setImmediate(iterate); 23 } else { 24 iterate();　　//最終發(fā)現(xiàn)是通過(guò)遞歸，在處理完成的回調(diào)函數(shù)中調(diào)用自身來(lái)實(shí)現(xiàn)同步 25 } 26 } 27 } 28 })); 29 sync = false; 30 } 31 iterate(); 32 };

之所以要列出eachOf的源碼，是因?yàn)槔锩嬗靡粋€(gè)變量來(lái)檢測(cè)異步遍歷執(zhí)行是否結(jié)束的方法相比我之前在一個(gè)項(xiàng)目中所用的方法來(lái)說(shuō)是更好的方案，所以覺得要寫一下。但是，還是存在一些疑問(wèn)：不理解eachOfSeries源碼中sync存在的意義，還有async.setImmediate(iterate)和iterate()這兩個(gè)語(yǔ)句的區(qū)別？

?

轉(zhuǎn)載于:https://www.cnblogs.com/Billy-Sherry/p/5200426.html

總結(jié)

以上是生活随笔為你收集整理的async框架源码研究的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問(wèn)題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。