defertothread benchmark

defert.py

from twisted.internet import reactor
from twisted.internet.threads import deferToThread
from twisted.internet.defer import inlineCallbacks
from time import time
import sys

def func(a):
    return a

@inlineCallbacks
def dtt():
    t1=0
    t2=0
    for i in xrange(10000):
        st=time()
        res = yield deferToThread(func,i)
        t1+=time()-st
        st=time()        
        res = func(i)
        t2+=time()-st
    print ("deferToThread: avg %.2f us, sync: avg %.2f us, %.2fx increase" % (t1/i*1000**2, t2/i*1000**2, (t1/i)/(t2/i)))
    reactor.callWhenRunning(dtt)

reactor.suggestThreadPoolSize(64)
for i in range(int(sys.argv[1])):
    reactor.callInThread(dtt)
reactor.run()