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()
insert_data.py 文件源码
python
阅读 27
收藏 0
点赞 0
评论 0
评论列表
文章目录