add multi-process

d572343e · 张彦钊 · ca0f9699 · d572343e
Commit d572343e authored Aug 25, 2018 by 张彦钊
Hide whitespace changes
Inline Side-by-side

Showing with 1 addition and 1 deletion

diaryQueueUpdate.py diaryQueueUpdate.py +1 -1

No files found.
--- a/diaryQueueUpdate.py
+++ b/diaryQueueUpdate.py
@@ -245,7 +245,7 @@ def user_update(device_id, city_id, queue_name,data_set_cid):

 def mult_iproecess_update(device_id, city_id, data_set_cid):
    queue_name_list = ["native_queue","nearby_queue","nation_queue","megacity_queue"]
-    pool = Pool(2)
+    pool = Pool(4)
    for queue_name in queue_name_list:
        pool.apply_async(user_update, (device_id, city_id, queue_name,data_set_cid,))
    pool.close()