更新定时任务

src/main/java/com/fdkk/fdkkmeta/task/UpdateFrameMetaTask.java

@@ -23,14 +23,16 @@ public class UpdateFrameMetaTask {
    @Autowired
     UserService userService;
 
-   @Scheduled(initialDelay=1000, fixedDelay=1000/30)
+    @Scheduled(initialDelay=1000, fixedDelay=2000)
    public void updateFrameMetadata(){
        List<UserEntity> userOnline = userService.findUserOnline(true);
        log.info("进入定时任务{}", ArrayUtil.isNotEmpty(userOnline)?userOnline.size():0);
-       for (UserEntity userEntity : userOnline) {
-            redisCache.setCacheObject("updateFrameMetadata:"+userEntity.getUserId(),null);
-       }
-
+       //使用并行流处理数据
+       userOnline.parallelStream().forEach(
+               userEntity -> {
+                   redisCache.setCacheObject("updateFrameMetadata:"+userEntity.getUserId(),null);
+               }
+       );
 
    }
 }