Javascript/Node.js異步循環

Question

我遇到節點的異步性質問題。有人可以用這段代碼來幫助我。由於各種原因，我一次只能插入1行到我正在使用的數據庫中。實際上，如果我可以添加一個短暫的延遲來每秒只向數據庫中插入1行，那將會更好。

這是我的js代碼的一小部分。

console.log('*** Inserting Records ***') 
insertPromises = [] 
_.each(dbRecords, function (item) { 
    var insertItem = buildRecord(item) 
    insertPromises.push(conn.create(insertItem)) 
}) 
Promise.all(insertPromises).then(function (res) { 
    _.each(res, function (item) { 
     if (!item.success) { 
      console.log("### Error ### " + JSON.stringify(res[i].errors)) 
     } 
    }) 
    console.log('*** Inserted ' + res.length + ' Contacts') 
}) 

我的主要問題是我怎麼能強制循環等待conn.create承諾繼續循環之前解決？有沒有辦法讓循環速度減慢到每秒1次？

Answer 1

而不是使用上面發佈的遞歸代碼，您可以檢查async/await模型。

使用，這將是的一個例子：

async function processRecords(dbRecords) { 

    for (let item of dbRecords) { 
     try { 
      let insertItem = buildRecord(item) 
      await conn.create(insertItem) 
      await delay(1000) 
     } catch (e) { 
      //handle error... 
     } 
    } 

} 

function delay(ms) { 
    return new Promise((resolve) => setTimeout(resolve, ms)) 
} 

processRecords(dbRecords) 

這是ES7代碼，你需要babel編譯器來改變它。

如果你很難跟上承諾並且想要堅持類似sync的代碼，那麼使用類似的東西可能會更好。

Answer 2

一個簡單的解決方案是跟蹤「插入計數」，即當前成功插入記錄的數量。這將是你的數組指針。使用一種方法來創建每個單獨的承諾，並在每次成功響應時將「插入計數」增加1。

let insertCount = 0; 

function insertNextRecord() { 
    conn.create(buildRecord(dbRecords[insertCount]).then(function(res){ 
     insertCount += 1; 
     insertNextRecord(); 
    }).catch(function() { 
     console.log('Error while inserting record ' + insertCount); 
    }); 
} 

insertNextRecord(); 

這不是測試，我在調查你不顯示代碼的幾個假設。

這個例子假設：

• dbRecords是一個數組
• conn.create返回一個承諾對象

明確添加的延遲，你可以在then方法，像這樣內使用超時：

let insertCount = 0; 

function insertNextRecord() { 
    conn.create(buildRecord(dbRecords[insertCount]).then(function(res){ 
     insertCount += 1; 
     setTimeout(function() { 
      insertNextRecord(); 
     }, 500); 
    }).catch(function() { 
     console.log('Error while inserting record ' + insertCount); 
    }); 
} 

insertNextRecord(); 

我也應該說這是不幸的，你必須這樣做。處理很多插頁時，這將非常緩慢。