使用封闭范围内的变量的函数节点数组
Node array of function using variables from enclosing scope
我正在尝试使用 async.parallel()
在 ip 列表上执行 dns.reverse()
。
代码如下:
var functions = [];
for (var i = 0; i < data.length; i++) {
var ip = data[i].ip;
var x = function(callback) {
dns.reverse(ip, (err, hostnames) => {
if (err) {
log.error("Error resolving hostname for [" + ip + '] ' + err);
return callback(null, err);
}
callback(null, hostnames);
});
};
functions.push(x);
}
async.parallel(functions, (err, results) => {
for(var i = 0; i < data.length; i++) {
data[i]['hostnames'] = results[i];
}
handler(null, data);
});
发生的事情是 dns.reverse()
被所有调用使用相同的 ip(数据数组中的最后一个)调用。可能是我做错了什么。有人可以解释我的错误吗?
第一个回调在整个 for 循环完成后执行,因为它是异步的。
ip 的值将是循环的最后一次迭代中的值。
你可以放一些 console.log 来了解真正发生的事情。
正确的做法可能是:
async.parallel(data.map(({ ip }) => callback => {
dns.reverse(ip, callback)
}), (err, results) => {
for (var i = 0; i < data.length; i++) {
data[i]['hostnames'] = results[i];
}
handler(null, data);
})
根据每个ip创建一个新的函数数组。
每个函数都会将其回调称为 dns.reverse.
此外,return 一个新数据数组可能更好,而不是在循环内更改数据:
(err, results) => {
const result = data.map((data, index) => ({
...data,
hostnames: results[index]
})
handler(null, result);
})
感谢@apokryfos,我得到了提示。为了使代码正常工作,我只需要在声明 ip 时使用 let 而不是 var。
var functions = [];
for (var i = 0; i < data.length; i++) {
let ip = data[i].ip;
var x = function(callback) {
dns.reverse(ip, (err, hostnames) => {
if (err) {
log.error("Error resolving hostname for [" + ip + '] ' + err);
return callback(null, err);
}
callback(null, hostnames);
});
};
functions.push(x);
}
async.parallel(functions, (err, results) => {
for(var i = 0; i < data.length; i++) {
data[i]['hostnames'] = results[i];
}
handler(null, data);
});
任何有兴趣了解以下内容的人可能会有所帮助:How do JavaScript closures work?
我正在尝试使用 async.parallel()
在 ip 列表上执行 dns.reverse()
。
代码如下:
var functions = [];
for (var i = 0; i < data.length; i++) {
var ip = data[i].ip;
var x = function(callback) {
dns.reverse(ip, (err, hostnames) => {
if (err) {
log.error("Error resolving hostname for [" + ip + '] ' + err);
return callback(null, err);
}
callback(null, hostnames);
});
};
functions.push(x);
}
async.parallel(functions, (err, results) => {
for(var i = 0; i < data.length; i++) {
data[i]['hostnames'] = results[i];
}
handler(null, data);
});
发生的事情是 dns.reverse()
被所有调用使用相同的 ip(数据数组中的最后一个)调用。可能是我做错了什么。有人可以解释我的错误吗?
第一个回调在整个 for 循环完成后执行,因为它是异步的。 ip 的值将是循环的最后一次迭代中的值。 你可以放一些 console.log 来了解真正发生的事情。
正确的做法可能是:
async.parallel(data.map(({ ip }) => callback => {
dns.reverse(ip, callback)
}), (err, results) => {
for (var i = 0; i < data.length; i++) {
data[i]['hostnames'] = results[i];
}
handler(null, data);
})
根据每个ip创建一个新的函数数组。 每个函数都会将其回调称为 dns.reverse.
此外,return 一个新数据数组可能更好,而不是在循环内更改数据:
(err, results) => {
const result = data.map((data, index) => ({
...data,
hostnames: results[index]
})
handler(null, result);
})
感谢@apokryfos,我得到了提示。为了使代码正常工作,我只需要在声明 ip 时使用 let 而不是 var。
var functions = [];
for (var i = 0; i < data.length; i++) {
let ip = data[i].ip;
var x = function(callback) {
dns.reverse(ip, (err, hostnames) => {
if (err) {
log.error("Error resolving hostname for [" + ip + '] ' + err);
return callback(null, err);
}
callback(null, hostnames);
});
};
functions.push(x);
}
async.parallel(functions, (err, results) => {
for(var i = 0; i < data.length; i++) {
data[i]['hostnames'] = results[i];
}
handler(null, data);
});
任何有兴趣了解以下内容的人可能会有所帮助:How do JavaScript closures work?