python twisted：延迟函数不会立即运行？

Question

我最近阅读了有关 python 扭曲框架的官方文档。 现在，我可以清楚地理解“延迟不做的事情：让你的代码异步”，当你调用阻塞函数时，你需要“twisted.internet.threads.deferToThread”函数来设置一个线程来运行阻塞函数.

我写了下面的demo来做一个测试：

from twisted.internet import reactor,defer,threads
import time
def delay(x):
    time.sleep(x)
    return "Time to wake up,you havs sleep %s second!" % x

def getres(res):
    print res
    reactor.stop()

d = threads.deferToThread(delay,3)
d.addCallback(getres)
print "Now my pieces of code not blocking!"

import time
time.sleep(3)
print "now to get the result of the delayed fuction"
reactor.run()

但得到的结果却出乎我的意料：

(myspace) [root@master myspace]# python ttt.py 
Now my pieces of code not blocking!
now to get the result of the delayed fuction
Time to wake up,you havs sleep 3 second!

为什么输出第二行（“现在得到延迟函数的结果”）后仍然有 3 秒延迟，而不是立即输出第三行。 我不知道为什么我的代码总共睡眠 6 秒，不是必须是 3 秒吗？如果必须是 6，是不是说“延迟只是延迟了阻塞功能，而不是在 d 之后立即运行该功能。添加回调（getres）”？ 如果我只想延迟 3 秒，我该怎么办。 您的回答将不胜感激。

Answer 1

您的代码通过两个sleep(3)。甚至在你启动反应堆并让 Twisted 运行之前。另一个在delay 函数中。

现在第一次等待 3 秒后，反应堆开始启动。这也是线程实际开始的地方。大约 3 秒后它返回并打印结果。总共需要超过 6 秒。

或者简而言之：Twisted 在反应堆运行之前不做任何事情。