学习是最好的投资!
當然咯,因為你並發量是5,但是你的queue中並沒有fork callback,所以並發量是5,沒有結束也不會調新的咯。
fork callback
var async = require('async'); var q = async.queue(function(data, callback) { console.log(data.name); // fork callback callback(); }, 5); for(var i = 0; i < 10; ++i) { q.push({ name: 0 }) }
雷雷
少了回呼
用於處理排隊任務的非同步函數,完成後必須呼叫其回呼(err)參數,並使用可選錯誤作為參數。如果您想處理單一任務的錯誤,請將回呼傳遞給 q.push()。透過(任務、回調)呼叫。
當然咯,因為你並發量是5,但是你的queue中並沒有
fork callback
,所以並發量是5,沒有結束也不會調新的咯。雷雷
少了回呼
用於處理排隊任務的非同步函數,完成後必須呼叫其回呼(err)參數,並使用可選錯誤作為參數。如果您想處理單一任務的錯誤,請將回呼傳遞給 q.push()。透過(任務、回調)呼叫。