我试图弄清楚如何使用扭曲使我的代码更加异步。
deferred_obj.callback然而，链式回调不会被认为是异步的，因为它们是链式的，并且事件循环将继续同时触发它们中的每一个，直到不再有，对吧？
但是，如果我有一个延迟对象，并且我将 deferred_obj.callback 作为其回调附加，d.addCallback(deferred_obj.callback)那么这将被认为是异步的，因为 deferred_obj 正在等待数据，然后传递数据的方法正在等待数据同样，一旦我 d.callback 'd' 对象处理数据然后它调用 deferred_obj.callback 但是由于该对象是延迟的，与链式回调的情况不同，它将异步执行......对吗？
假设我的所有代码都是非阻塞的，这意味着链式回调不是异步的，而链式延迟是异步的，对吗？
回调（默认情况下）是同步的。然而，正如Twisted 文档指出的那样：
如果您需要一个 Deferred 来等待另一个，您需要做的就是从添加到 addCallbacks 的方法中返回一个 Deferred。
因此，您可以使用它在回调链中进行一些异步处理。让我们这样做：
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()
有点，但在这种类型的事件处理中没有并发。在代码返回事件循环之前，不会调用新的回调。所以回调链是同步的。它仅在事件循环中是异步的。
这是此类编程的一个警告，处理程序执行速度最快，并尽快返回事件循环。它不应该在处理程序中执行任何耗时的任务。
使用延迟不会使您的代码异步。
import time
from twisted.internet import defer
from twisted.internet import reactor
def blocking(duration, deferred):
print "start blocking"
time.sleep(duration)
print "finished blocking"
deferred.callback(True)
def other_task():
print "working..."
reactor.callLater(1, other_task)
def finish(result):
print "stopping reactor in 2sec"
reactor.callLater(2, reactor.stop)
def failed(reason):
print reason
print "stopping reactor in 2sec"
reactor.callLater(2, reactor.stop)
def main():
d = defer.Deferred()
d.addCallbacks(finish, failed)
reactor.callLater(0, blocking, 5, d)
if __name__ == "__main__":
reactor.callLater(0, other_task)
main()
reactor.run()
如果您有长时间运行的同步代码，您可以使用协作器 (twisted.internet.task) deferToThread 或将其分解为短迭代