def runWithConnection(func, *args, **kwargs):
    return threads.deferToThreadPool(pool._reactor, pool.threadpool, pool._runWithConnection, func, *args, **kwargs)
def runWithConnection(func, *args, **kwargs):
    return threads.deferToThreadPool(pool._reactor, pool.threadpool, pool._runWithConnection, func, *args, **kwargs)