python - 扭曲的延迟/回调和异步执行

Question

我正在尝试弄清楚如何使用 twisted 使我的代码更加异步。

• 一个函数返回一个延迟对象
• 然后我添加一个回调列表
• 在延迟函数通过 deferred_obj.callback 提供一些结果后调用第一个回调
• 然后，在回调链中，第一个回调会处理数据并调用第二个回调
• 等等

然而，链式回调不会被视为异步，因为它们是链式的，并且事件循环将继续同时触发它们中的每一个，直到没有更多，对吧？

但是，如果我有一个延迟对象，并且我将 deferred_obj.callback 作为其回调附加在 d.addCallback(deferred_obj.callback) 中，那么这将被视为异步，因为 deferred_obj 是等待数据，然后将传递数据的方法也在等待数据，但是一旦我 d.callback 'd' 对象处理数据然后它调用 deferred_obj.callback 但是因为这个对象被推迟，不像这种情况链式回调，它将异步执行...对吗？

假设我所有的代码都是非阻塞的，这意味着链式回调不是异步的，而链式延迟是异步的，对吗？

Answer 1

回调(默认情况下)是同步的。但是，作为 Twisted doc指出:

If you need one Deferred to wait on another, all you need to do is return a Deferred from a method added to addCallbacks.

因此您可以使用它在回调链中执行一些异步处理。让我们这样做:

from twisted.internet import reactor, defer

def callback_func_2(result, previous_data):
    # here we pass the result of the deferred down the callback chain
    # (done synchronously)
    print "calling function 1 on result:%s with previous result:%s" % (result, previous_data)
    return result

def callback_func(result):
    #let's do some asynchronous stuff in this callback
    # simple trick here is to return a deferred from a callback 
    # instead of the result itself.
    # 
    # so we can do asynchronous stuff here, 
    # like firing something 1 second later and have 
    # another method processing the result
    print "calling function 1 on result:%s" % result
    d = defer.Deferred()
    reactor.callLater(1, d.callback, "second callback")
    d.addCallback(callback_func_2, result)
    return d

def do():
    d = defer.Deferred()
    reactor.callLater(1, d.callback, "first callback")
    d.addCallback(callback_func)
    return d

do()
reactor.run()