run_async_threaded

def run_async(f, lock=None):
    import weakref
    from threading import Thread
    def args_wrapper(*args, **kwargs):
        class FunctionRunner(Thread):
            def run(self):
                if lock is not None: lock.acquire()
                try:
                    self.result = f(*args, **kwargs)
                finally:
                    if lock is not None: lock.release()
        t = FunctionRunner()
        t.start()
        def callback():
            t.join()
            return t.result
        proxy = weakref.proxy(callback)
        return proxy
    return args_wrapper