gpt4 book ai didi

javascript - 并行 promise 的流畅构造

转载 作者:搜寻专家 更新时间:2023-11-01 00:33:05 26 4
gpt4 key购买 nike

我的问题是关于 BlueBird 中 promise 的优雅并行化当您需要将上下文和参数都传递给构建 promise 的函数时。

为了让我的问题易于理解和测试,我做了一个没有依赖关系的例子。

假设我进行涉及异步“计算机”(必须释放其资源)的计算 ( 1/(xxx) + 1/(x*x) )。正方形和立方体是异步和独立计算的。

我可以这样计算:

InitComputer(2) // returns a promise
.then(invert)
.then(function(arg){
return Promise.all([
proto.square(arg),
proto.cube(arg)
]);
}).spread(function(sq, cu){
this.set(sq + cu);
}).catch(function(err){
console.log('err:', err);
}).finally(endComputer);

但我发现 all 的这种用法与理论上可能的情况相比太重了。当您将函数作为参数传递给 then 时,它会被执行。当您将函数传递给 all 时,它们不是,出现错误。我怀疑我缺少实用程序或模式...

是否有解决方案可以将其更改为这种风格的更简单的东西:

InitComputer(2)
.then(invert)
.all([
proto.square,
proto.cube
]).spread(function(sq, cu){
this.set(sq + cu);
}).catch(function(err){
console.log('err:', err);
}).finally(endComputer);

?

我可能会破解 Promise.prototype.all或定义一个新函数以避免增加多态性,但我只对不涉及修改我不拥有的对象的解决方案感兴趣。


附件:

这里是如何定义我的测试的“计算机”:

var Promise = require("bluebird");

function Computer(){}
function InitComputer(v){
// initializing a computer is asynchronous and may fail hence the promise
var c = new Computer(), resolver = Promise.defer();
setTimeout(function(){
if (v>1) resolver.resolve(v);
else resolver.reject(new Error("bad value: "+v));
},100);
return resolver.promise.bind(c);
}
var proto = Computer.prototype;
proto.square = function(x){
// imagine this really uses the computer and is asynchronous
if (!this instanceof Computer) throw new Error('not a computer');
return x*x
}
proto.cube = function(x){ return x*x*x }
proto.set = function(v){ this.value = v }

function endComputer(){
// releases resources here
console.log('value:', this.value);
}

// this asynchronous function doesn't involve or know the computer
function invert(v){ return 1/v }

最佳答案

您不必在那里使用 Promise.all。而不是做:

.then(function(arg){
return Promise.all([
proto.square(arg),
proto.cube(arg)
]);
}).spread(...

您可以简单地使用:

.then(function(arg){
return [proto.square(arg), proto.cube(arg)];
}).spread(...

如果我们在 node.js 中有箭头函数,它会像这样简单:

.then(arg => [proto.square(arg), proto.cube(arg)]).spread(...

Promise.all 用于当您需要开始至少包含 2 个 promise 的 promise 链时。例如:

var promise1 = somePromise();
var promise2 = somePromise2();

// Start the chain here
Promise.all([promise1, promise2])
.spread(function(value1, value2) {
// ...
});

关于javascript - 并行 promise 的流畅构造,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/21015511/

26 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com