当每个回调都有不同的参数时，将 Twisted Deferred 与并行回调一起使用

Question

我想创建一个延迟，如下所示：

f1(x1) 和 f2(x2) 并行执行（可以这么说） 完成后，我运行 f3() 如果我有相同的参数，我会运行：

d = Deferred()
d.addCallbacks(f1)
d.addCallbacks(f2)
d.addCallback(lambda x: f3())
d.callback(x1)

以便将 x1 传递给 f1 和 f2。但我需要 f1 来获取 x1 等等。

我该怎么做？

谢谢。

Answer 1

我不确定我是否正确理解了您的用例，但这似乎是 DeferredList 效果特别好。

d1 = function_that_returns_a_deferred_1(x1)
d2 = function_that_returns_a_deferred_2(x2)
d = DeferredList([d1, d2])
d.addCallback(lambda ign: f3())

这样，只有当 d1 和 d2 都完成后，f3 才会被执行。