insert_data.py 文件源码

def insert_all():
    import warnings
    warnings.filterwarnings("ignore")

    queue = multiprocessing.JoinableQueue()

    get_bug_list(queue)

    # print("totally: ", queue.qsize())

    process_num = multiprocessing.cpu_count() * 2

    for i in range(process_num):
        t = multiprocessing.Process(target=get_one_bug, args=(queue,))
        t.start()

    queue.join()

    print("finished")
    save_fail_queue()