java分批处理逻辑

　　public void updateUserLoseRelationStatus() {   //避免数据过多分批执行   int total = enterpriseWechatTeacherUserRelationLogDao.selectCountLoseRelation();    int totalPage = (total % ConstansCommon.BATCH_MAX) == 0 ? (total / ConstansCommon.BATCH_MAX) : (total / ConstansCommon.BATCH_MAX) + 1;    AtomicInteger updateCount = new AtomicInteger();    while (totalPage > 0) {     int offset = (totalPage - 1) * ConstansCommon.BATCH_MAX;     List> userList = enterpriseWechatTeacherUserRelationLogDao.selectLoseRelation(offset, ConstansCommon.BATCH_MAX);      if (CollUtil.isEmpty(userList)) {       totalPage--;       continue;     }      userList.stream().forEach(userMap -> {       Long userId = MapUtils.getLong(userMap, ＂user_id＂);     Long teacherId = MapUtils.getLong(userMap, ＂teacher_id＂);      if (Objects.nonNull(userId) && Objects.nonNull(teacherId)) {       int i = crmUserRelationCollectService.updateStatusByUserTeacher(userId, teacherId, UserStatusEnum.LOSE_RELATION.getCode());       updateCount.addAndGet(i);     }   });    totalPage--; } log.info(＂updateCount={}＂, updateCount); }