承諾問題

Question

我在下面的函數中遇到了一個小問題。 Promise.map不會等待Folder.create完成並遍歷下一個值。

Promise.map(name, function(na){ 
 
    return fs.stat(na.url, function(err, stats){ 
 
    if (typeof stats === 'undefined'){ 
 
     console.log("file doesn't exist"); 
 
     return Folder.create(na).then(function(fd){ 
 
     return mkdirp(root + product.url).then(function(){ 
 
      console.log("Folder Created"); 
 
      return null; 
 
     }); 
 
     }, function(err){ 
 
     console.log(err); 
 
     return reject({message: "Error when creating the folder"}); 
 
     }); 
 
    } 
 
    }); 
 
}).then(function(){ 
 
    console.log('Iteration Done'); 
 
    return resolve({message: "Folder Created!"}); 
 
}); 
 

 
// I GOT : 
 
//file doesn't exist 
 
//file doesn't exist 
 
//file doesn't exist 
 
//Iteration Done 
 
//file doesn't exist 
 
//file doesn't exist 
 
//file doesn't exist 
 
//Iteration Done 
 
//Folder Created 
 
//Folder Created 
 
//Folder Created 
 
//Folder Created 
 
//Folder Created 
 
//Folder Created

Answer 1

有幾個問題在這裏：

1. Promise.map()運行操作的並行每個數組元素，不連續。如果您希望它們連續運行，您可以將{concurrency: 1}作爲選項通過Promise.map()或使用Promise.mapSeries()。

2. fs.stat()所以你的主要回調Promise.map()沒有返回一個承諾等全Promise.map()基礎設施不知道如何等待您的任何結果，不返回的承諾。您可以通過promisify fs.stat()解決該問題。

3. 您似乎在使用anti-pattern而您的resolve()和reject()調用此處。你不會顯示那些來自哪裏的外部定義，但你應該使用從Promise.map()返回的承諾，而不是這樣做。

下面是他們能夠成功地並行運行：

var fs = Promise.promisifyAll(require('fs')); 

Promise.map(name, function(na){ 
    return fs.statAsync(na.url).then(function(err, stats){ 
    if (typeof stats === 'undefined'){ 
     console.log("file doesn't exist"); 
     return Folder.create(na).then(function(fd){ 
     return mkdirp(root + product.url).then(function(){ 
      console.log("Folder Created"); 
      return null; 
     }); 
     }, function(err){ 
     console.log(err); 
     return Promise.reject({message: "Error when creating the folder"}); 
     }); 
    } 
    }); 
}).then(function(){ 
    console.log('Iteration Done'); 
    return ({message: "Folder Created!"}); 
}); 

如果你想與藍鳥連續運行你的業務，你可以通過{concurrency: 1}到Promise.map()：

Promise.map(name, fn, {concurrency: 1}).then(...); 

或者用途：

Promise.mapSeries(name, fn).then(...) 

Answer 2

fs.stat是一個回調類型的函數，因此，不返回的承諾。你應該修改你的代碼是這樣的

// This might not work directly. I haven't tried to run it 
Promise.map(name, function(na) { 
    return new Promise(function(resolve, reject) { 
     fs.stat(na.url, function(err, stats) { 
      if (typeof stats === 'undefined') { 
       console.log("file doesn't exist"); 
       Folder.create(na).then(function(fd) { 
        return mkdirp(root + product.url); 
       }).then(function() { 
        console.log("Folder Created"); 
        resolve(); 
       }).catch(function(err) { 
        console.log(err); 
        reject({ 
         message: "Error when creating the folder" 
        }); 
       }); 
      } else { 
       resolve(); 
      } 
     }); 
    }); 
}).then(function() { 
    console.log('Iteration Done'); 
    return { 
     message: "Folder Created!" 
    }; 
});