engines.py 文件源码

def multithread_engine(object,redirect,credentials):

    start_time = datetime.datetime.now()
    index = 0

    if(object == initialize.ntw_device):
        arguments = None
    if(object == initialize.switchport):
        arguments = credentials
    for i in object:
        my_thread = threading.Thread(target=getattr(object[index],redirect) , args=(arguments,))
        my_thread.start()

        index = index + 1

    main_thread = threading.currentThread()
    for some_thread in threading.enumerate():
        if some_thread != main_thread:
            print(some_thread)
            some_thread.join()

    print("\n")
    print("TIME ELAPSED: {}\n".format(datetime.datetime.now() - start_time))