承诺问题

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!" 
    }; 
});