執行

Question

假設我有一些代碼，這樣

function execute() { 
    var tasks = buildListOfTasks(); 
    // ... 
} 

buildListOfTask創建的功能陣列。函數是異步的，可能會發出HTTP請求或/和執行數據庫操作。

如果任務列表顯示爲空或執行了所有任務，則需要再次重複相同的execute例程。再說一遍，說「無限循環」。所以，它就像應用程序一樣。

我完全可以理解如何在同步世界中實現這一點，但有點困惑如何使它在node.js異步世界中成爲可能。

Answer 1

使用async.js和它的隊列對象。

function runTask(task, callback) { 
    //dispatch a single asynchronous task to do some real work 
    task(callback); 
} 
//the 10 means allow up to 10 in parallel, then start queueing 
var queue = async.queue(runTask, 10); 

//Check for work to do and enqueue it 
function refillQueue() { 
    buildListOfTasks().forEach(function (task) { 
    queue.push(task); 
    }); 
}  

//queue will call this whenever all pending work is completed 
//so wait 100ms and check again for more arriving work 
queue.drain = function() { 
    setTimeout(refillQueue, 100); 
}; 

//start things off initially 
refillQueue(); 

Answer 2

我認爲你必須使用async.js，可能是並行功能。 https://github.com/caolan/async#parallel

在全局回調中，只需調用execute來進行遞歸調用即可。

async.parallel(tasks, 
    function(err, results){ 
     if(!err) execute(); 
    } 
); 

Answer 3

如果你已經熟悉了，async庫，你可以使用​​作爲最終回調重新啓動任務：

function execute(err) { 
    if (!err) { 
     async.series(buildListOfTasks(), execute); 
    } else { 
     // ... 
    } 
}