# 多线程执行队列中的消息
cdn_list = []
non_cdn_list = []
non_cdn_ip_list = []
non_parse_list = []
thread_num = 10
threads = []
for i in range(thread_num):
t = threading.Thread(target=work, args=(q, cdn_list, non_cdn_list, non_parse_list, non_cdn_ip_list))
threads.append(t)
t.start()
for t in threads:
t.join()
main()

举报 0