run_in_thread

run_in_thread

import threading
from functools import wraps
threads = []

def run_in_thread(join=False):
    def decorator(f):
        @wraps(f)
        def wrapper(*args, **kwds):
            t = threading.Thread(target=f,args=args,kwargs=kwds)
            threads.append(t)
            t.start()
            if join:
                for t in threads:
                    try:
                        t.join()
                    except:
                        pass
        return wrapper
    return decorator