atr3.py 文件源码

def asynchronous():
    threads = []
    threads.append(gevent.spawn(loader))
    for i in xrange(0, workers):
        threads.append(gevent.spawn(worker, i))
    threads.append(gevent.spawn(writer_valid))
    threads.append(gevent.spawn(state))
    if invunma:
        threads.append(gevent.spawn(writer_invalid))
        threads.append(gevent.spawn(writer_unmatched))
    if grabactiv:
        threads.append(gevent.spawn(writer_grabber))
    start = timer()
    gevent.joinall(threads)
    end = timer()
    if grabactiv:
        if snap_shot:
            output_filename = "grabbed_" + time.strftime("%Y%m%d-%H%M%S")
            shutil.make_archive(output_filename, 'zip', "grabbed")
    print "[INFO]Time elapsed: " + str(end - start)[:5], "seconds."
    print "[INFO] Done."
    evt.set()  # cleaning up