python twisted: отложенная функция не запускается немедленно?

Question

Я недавно прочитал официальные документы о скрученной каркасе python. Теперь я могу четко понимать, что «Отложенные действия не делают: сделайте свой асинхронный код». Когда вы вызываете функцию блокировки, вам нужна функция «Twisted.internet.threads.deferToThread», чтобы настроить поток для запуска блокировки функции.

Я wrtite следующую демонстрацию, чтобы сделать тест:

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() 

Но результат я получил из моего expection:

(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 секунды задержки после вывода второй line («теперь, чтобы получить результат задержки fuction») вместо вывода третьей строки. Я не знаю, почему мой код спящий 6 секунд, не должно ли оно быть 3 секунды? Если это должно быть 6, то это означает, что «отложенный только отсрочил блокировку, не запускает функцию сразу после d .addCallback (getres) "? , если я хочу только задержка на 3 секунды, что я могу сделать. Ваш ответ будет высоко оценен.

Answer 1

Ваш код проходит через два sleep(3). Один перед тем, как вы начнете работать в реакторе и запустите его. Другой - в функции delay.

Теперь после ожидания в первый раз, реактор запускается. Это тот момент, когда поток действительно начинается. Примерно через 3 с он вернется и результат будет напечатан. Должно брать чуть больше 6 с.

Вкратце: скрученный ничего не делает до запуска реактора.