(节点)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(...)
链是一种相当麻烦的构建方式newDataItem
; Promise.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)
都可以在内部或外部执行。我在上面将它们分开以演示两种可能性。
我有一组包含用户信息的对象。
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(...)
链是一种相当麻烦的构建方式newDataItem
;Promise.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)
都可以在内部或外部执行。我在上面将它们分开以演示两种可能性。