Commit fc55a89a authored by 张彦钊's avatar 张彦钊

add print

parent ce40dfa1
......@@ -274,6 +274,7 @@ def user_update(device_id, city_id, queue_name,data_set_cid,total_video_id):
def multi_proecess_update(device_id, city_id, data_set_cid,total_video_id):
queue_name_list = ["native_queue","nearby_queue","nation_queue","megacity_queue"]
print("multi")
pool = Pool(4)
for queue_name in queue_name_list:
pool.apply_async(user_update, (device_id, city_id, queue_name,data_set_cid,total_video_id,))
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment