减少线程数量

dy_userinfo_update.py

@@ -56,6 +56,6 @@ if __name__ == "__main__":
 
     rds = RdsUserInfoList()
     print(time.strftime("%Y-%m-%d %H:%M:%S", time.localtime()) + ' ' + ' 开始执行，待更新直播队列长度：' + str(rds.get_len()))
-    for i in range(1, 50):
+    for i in range(1, 30):
         task = threading.Thread(target=scrape, name=i)
         task.start()  # 准备就绪,等待cpu执行

rds_model/rds_user_info_list.py

@@ -18,7 +18,7 @@ class RdsUserInfoList:
     # 新增待更新用户
     def put_wait_update_user(self, sec_uid):
         key = 'BrandLiveData.DyWaitingUpdateUserInfoList'
-        return self.redis.lpush(key, sec_uid)
+        return self.redis.rpush(key, sec_uid)
 
     # 已获取好的用户信息加入到列队
     def put_user_info(self, data):