我天真地认为我可以将 .map()
链接到 Promise.map()
但看来我错了。当并发性很高时,我遇到了一个恼人的问题:通过单元测试但在现实世界测试中失败。我认为这使得这成为 Stack Overflow 上值得注意的问题。
我更改了代码以使用通常的 .then()
模式,现在它似乎每次都能工作。
这里的问题是与 JS 中的数组不同,我无法将 .map()
链接到 Promise.map()
还是我做错了什么?我注意到我清理了工作版本中的一些 lint 问题,但这似乎并没有对行为产生影响。
下面是随机失败的代码(当并发性较高时),而在低并发性单元测试中似乎始终有效。请注意所有称为返回 promise 的函数。
// this has concurrency issues. occasionally the function
// returns [{ key: undefined: val: correct }]
db.assocThreeFewCountsGet = function(manyid, atype) {
counts = [];
return db.assocThreeFewDistinctGet(manyid, atype)
.then(r => {
console.log('Distinct', r); // shows there are valid IDs
counts = r;
return Promise.map(r, fewid => {
return db.assocCount(manyid, fewid);
}).map((el, idx) => {
return { key: counts[idx], val: el };
});
});
};
// this appears to work correctly. key: and val: are correct
db.assocThreeFewCountsGet = function(manyid, atype) {
var ids;
return db.assocThreeFewDistinctGet(manyid, atype)
.then(r => {
ids = r;
console.log('Distinct IDs:', ids); // shows there are valid IDs
return Promise.map(ids, fewid => {
return db.assocCount(manyid, fewid);
});
}).then(counters => {
return counters.map((el, idx) => {
return { key: ids[idx], val: el };
});
});
};
最佳答案
那个 counts = [];
赋值是可疑的,似乎 create a global variable 。这会导致各种问题,包括引用异步方法并发执行中最新数组的计数。另外,在您的工作代码中,您有用于相同目的的var ids
,它对于每个调用都是本地的。
如果您在其他地方不需要 counts
,请使用以下命令修复您的代码
db.assocThreeFewCountsGet = function(manyid, atype) {
return db.assocThreeFewDistinctGet(manyid, atype)
.then(counts => {
console.log('Distinct', counts); // shows there are valid IDs
return Promise.map(counts, fewid => {
return db.assocCount(manyid, fewid);
}).map((el, idx) => {
return { key: counts[idx], val: el };
});
});
};
关于javascript - Promise.map.map 链在并发时失败但通过单元测试,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/43331451/