[Twisted-Python] thread pool question

Manlio Perillo manlio_perillo at libero.it
Thu Mar 22 13:09:07 MDT 2007


Rutt, Benjamin ha scritto:
>  From 
> _http://twistedmatrix.com/projects/core/documentation/howto/threading.html_: 
> 
> 
> I copied the code below and ran it as:
> 
>       $ cat twisted-threadpool.py
>       #!/usr/bin/env python
> 
>       from twisted.internet import reactor
> 
>       def aSillyBlockingMethod(x):
>           import time
>           time.sleep(2)
>           print x
> 
>       # run method in thread
>       reactor.callInThread(aSillyBlockingMethod, "2 seconds have passed")
> 
>       $ ./twisted-threadpool.py
>       2 seconds have passed
> 
> But I note that the program never stops. 

You should use deferToThread.

from twisted.internet import threads

d = threads.deferToThread(aSillyBlockingMethod, "2 seconds have passed")
d.addBoth(reactor.stop)



Regards  Manlio Perillo




More information about the Twisted-Python mailing list