'called in the main reactor thread. Makes sure the pool
is not locked before continuing.'

def callInThread(self, func, *args, **kwargs):

    if self._accept_new:
        threadpool.ThreadPool.callInThread(self, func, *args, **kwargs)
