按順序運行大量的承諾

Question

一個nodejs項目。我試着用承諾運行大量（大約100k）任務。我可以做的是將它轉換爲Q的workOnebyOne函數。有沒有更好的方法來做到這一點？

function workOnebyOne(items, worker) { 
    var deferred = Q.defer() 

    function _doNext() { 
    if (items.length === 0) { 
     deferred.resolve() 
     return 
    } 
    var item = items[0] 
    synchronize(worker, item) 
     .then(function (result) { 
     items = items.slice(1) 
     deferred.notify({ 
      item: item, 
      result: result 
     }) 
     _doNext() 
     }, function() { 
     items = items.slice(1) 
     _doNext() 
     }) 
    } 

    _doNext() 

    return deferred.promise 
} 

utils.workOnebyOne(tasks, workerFunction) 

Answer 1

你基本上是在這裏重新實施排隊。在藍鳥承諾（這也是更快，消耗更少的內存，這有助於100K任務），你會使用Promise.each。

在Q中，您通常可以在任務數組上使用.reduce將它們一次排隊 - 然而，使用100K元素在Q promise中創建100K承諾隊列會導致節點崩潰（同樣，這是Q，藍鳥或承諾時）它就好）。這（這裏不正確）解決方案看起來是這樣的：

var res = tasks.reduce(function(p, c){ 
    return p.then(function(){ return workerFunction(c); }); 
}, Q()); 

對於短隊列（< 500許諾Q）這工作得很好。

因此，由於舊的圖書館的選擇，並且由於涉及大量的承諾，您不能現實地解決它的優雅，使用類似回調隊列的方法非常接近您唯一的方式。我也避免notify，因爲它被刪除（甚至從Q），並且通常是一個糟糕的API（編寫不好）。

Answer 2

我花了一些時間尋找簡單而優雅的解決方案。我發現只有一些提示和討論，但沒有現成的例子。最後，我發現在https://github.com/kriskowal/q/issues/606，結果什麼都爲我工作可以分離和推廣這樣的討論：

function workOneByOne(items, someAsyncFuntionReturningPromise) { 
    var lastResultPromise = items 
    .map(function(item) { 
     return function(previousResult) { 
     /* 
     * this function has to: 
     * - process result from previous item processed if any 
     * - call the async job 
     * - return promise of the job done 
     */ 
     if (previousResult) { 
      // process result here 
     } 

     return someAsyncFuntionReturningPromise(item); 
    }}) 
    .reduce(Q.when, Q()); 

    return lastResultPromise; 
} 

並且如果沒有可用的函數返回的承諾，你可以撥打上面

workOneByOne(items, Q.nfbind(someAsyncFunctionWithCallback))