(节点)Dynamic 承诺 运行 n 次

(Node) Dynamic promises that run n-times

我有一组包含用户信息的对象。

var names=[{name: 'yoda', 
            address:'123 Compton', 
            email:'yodalicious@force.com'},
            {name: 'darth vader', 
            address:'69 harlem', 
            email:'elevader@force.com'},{....}]

这是一个可以包含 100 到 1000 个用户的列表。 问题是我需要 request/pull 来自网络和数据库的每个用户的信息,并创建一个包含每个用户更多详细信息的新数组。这将是 3 个来源。现在每次拉动都需要 10 毫秒到 1 分钟。 这就是我跳到承诺的地方。 ("native-promise-only"),例如:

require("native-promise-only");

function getFile(file) {
    return new Promise(function(resolve){
        fakeAjax(file,resolve);
    });
}
//Recursive call
function recursivePromise(originalArray, newArray){
 if(isEmpty(originalArray) ){
  store(newArray);
  display(newArray);
}
else{
  var currentItem = originalArray[0];
  var p1 = getFile(currentItem.name);
  var p2 = getFile(currentItem.address );
  var p3 = getFile(currentItem.email);

  var newDataItem={};
  p1.then(function(msg){
    //TODO check status
    newDataItem.nameinfo= msg;
    return p2;
  })

  .then(function(msg){
    //TODO check status
    newDataItem.addressinfo= msg
    return p3;
  })

  .then(function(msg){
    newDataItem.emailinfo= msg
    newArray.add(newDataItem);
    recursivePromise(originalArray.shift(), newArray)
  });
}
}
var new_array=[];
recursivePromise(names, new_array);

这是一个粗略的代码,我有类似的东西而且可以用!有些。但是我身上的一个错误告诉我,我可能正在设置一个未来的失败。我递归地这样做是因为 'names' 中项目的位置很重要。所以他们需要按顺序处理。

我所看到的问题 :

编码错误:

  • fruits 不知从何而来;大概 originalArray.shift() 是有意的。
  • array.shift() 从数组中删除第 0 个元素,returns 删除的元素,而不是数组。
  • originalArray会被摧毁,这不是一个好主意。
  • .add()不是数组方法,大概是.push()的意思。

模式问题:

  • p1.then(...).then(...)链是一种相当麻烦的构建方式newDataItemPromise.all(p1, p2, p3).then(...) 将更具可读性,在单个表达式中构建 newDataItem
  • 不需要递归;该过程将更简单地编码为 ...; Promise.all(arrayOfPromises).then(function(newArray) {...});(这是 Promise.all() 的第二次使用);尽管 promises 会以他们喜欢的任何顺序结算,newArray 将与 originalArray.
  • 一致
  • newArray可以内部生成,不需要传入[].
function process(originalArray) {
    var promises = originalArray.map(function(currentItem) {
        var p1 = getFile(currentItem.name);
        var p2 = getFile(currentItem.address);
        var p3 = getFile(currentItem.email);
        return Promise.all([p1, p2, p3]).then(function(results) {
            return {
                nameinfo: results[0],
                addressinfo: results[1],
                emailinfo: results[2]
            };
        });
    });
    return Promise.all(promises).then(function(newArray) {
        display(newArray);
        return newArray;
    });
}
process(names).then(function(newArray) {
    store(newArray);
});

display(newArray)store(newArray) 都可以在内部或外部执行。我在上面将它们分开以演示两种可能性。