處理的消息隊列和使用異步

Question

我寫的循環，並增加了消息隊列（Azure存儲隊列），像這樣一個小的測試節點的應用程序：

var queueService = azure.createQueueService(); 
var queueName = 'taskqueue'; 

// other stuff like check if created 

// loop called after queue is confirmed 

for (i=0;i<1000;i++){ 
    queueService.createMessage(queueName, "Hello world!", null, messageCreated); 
} 

// messageCreated does nothing at the moment, just logs to console 

我試圖重寫到處理一百萬個創建使用異步來控制並行運行的工作者函數的數量。這比任何事情都是一次學習練習。

https://github.com/caolan/async#queue

這是異步的隊列的基本設置和我無所適從，以什麼我需要改變我的一種。我不認爲下面會工作：

var q = async.queue(function (task, callback) { 
    queueService.createMessage(queueName, task.msg, null, messageCreated); 
    callback(); 
}, 100); 


// assign a callback. Called when all the queues have been processed 
q.drain = function() { 
    console.log('all items have been processed'); 
} 

// add some items to the queue 
for(i=0;i<1000000;i++) { 
    q.push({msg: 'Hello World'}, function (err) { 
    console.log('finished processing foo'); 
    }); 
    console.log('pushing: ' + i); 
} 

我不完全掌握如何將它與異步一起拉。

Answer 1

這是你的錯誤：

var q = async.queue(function (task, callback) { 
    queueService.createMessage(queueName, task.msg, null, messageCreated); 
    callback(); 
}, 100); 

你在做什麼是創建隊列的消息，並隨即通過延續（調用回調）。你想要做的是通過傳遞給createMessage回調內部延續：

var q = async.queue(function (task, callback) { 
    queueService.createMessage(queueName, task.msg, null, function(error, serverQueue, serverResponse) { 
     callback(error, serverQueue, serverResponse); 
     messageCreated(error, serverQueue, serverResponse); 
    }); 
}, 100); 

現在的任務實際上已經被創建後，每個任務將報告整理。

編輯：createMessage回調的更新界面。