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

change argument

parent d572343e
......@@ -243,7 +243,7 @@ def user_update(device_id, city_id, queue_name,data_set_cid):
else:
print("日记队列为空")
def mult_iproecess_update(device_id, city_id, data_set_cid):
def multi_proecess_update(device_id, city_id, data_set_cid):
queue_name_list = ["native_queue","nearby_queue","nation_queue","megacity_queue"]
pool = Pool(4)
for queue_name in queue_name_list:
......@@ -258,7 +258,7 @@ def run():
for device_city in device_city_list:
start = time.time()
mult_iproecess_update(device_city[0], device_city[1], data_set_cid)
multi_proecess_update(device_city[0], device_city[1], data_set_cid)
end = time.time()
print("更新该用户队列耗时{}秒".format((end-start)))
print("end")
......@@ -270,7 +270,6 @@ if __name__ == "__main__":
# while True:
run()
# # TODO 上线后把预测用户改成多进程预测
......
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