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

好在有一種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個參數:worker函數和concurrency(并發度) // concurrency比較好理解,即并發的最大數量(本例為:2), // worker函數,是處理數據的方式,它接受2個參數(data, callback); // queue.drain // 可以給queue隊列加一個完工事件處理 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]);// 注:以上函數會執行2次循環,每次循環會總隊列中讀取2個數據(第一次100和300,第二次200); // 2次循環過后會執行drain函數,打印出'Completed'字符串和時間.

參考《JavaScript異步編程》 — 設計快速響應的網絡應用 P80~P82

總結

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

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。