很多情況下,使用async.series和async.paralle存在一個(gè)明顯的問題,即:
1.其任務(wù)隊(duì)列是靜態(tài)的,在其調(diào)用前,一定要明確任務(wù)隊(duì)列的數(shù)量,一旦明確了任務(wù)隊(duì)列的數(shù)量,就不能改變.
2.倘如要同時(shí)并發(fā)讀取上千個(gè)文件,使用async.paralle明顯不可能(各線程搶資源,根本不夠用),使用async.series…(運(yùn)行時(shí)間可想而知…)

好在有一種async.queue方法:

// async.queue var async = require('async'); function worker(data, callback) {console.log(data);callback(); } var concurrency = 2; var queue = async.queue(worker, concurrency); queue.push(1); queue.push(2); queue.push(3);// 注:async.queue有2個(gè)參數(shù):worker函數(shù)和concurrency(并發(fā)度) // concurrency比較好理解,即并發(fā)的最大數(shù)量(本例為:2), // worker函數(shù),是處理數(shù)據(jù)的方式,它接受2個(gè)參數(shù)(data, callback); // queue.drain // 可以給queue隊(duì)列加一個(gè)完工事件處理 var async = require('async'); function worker(data, callback) {setTimeout(callback, data); } var concurrency = 2; var queue = async.queue(worker, concurrency); var start = new Date; queue.drain = function() {console.log('Completed in ' + (new Date - start) + 'ms'); };queue.push([100, 300, 200]);// 注:以上函數(shù)會(huì)執(zhí)行2次循環(huán),每次循環(huán)會(huì)總隊(duì)列中讀取2個(gè)數(shù)據(jù)(第一次100和300,第二次200); // 2次循環(huán)過后會(huì)執(zhí)行drain函數(shù),打印出'Completed'字符串和時(shí)間.

參考《JavaScript異步編程》 — 設(shè)計(jì)快速響應(yīng)的網(wǎng)絡(luò)應(yīng)用 P80~P82

總結(jié)

以上是生活随笔為你收集整理的javascript --- 异步工作流的动态排队技术的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問題。

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