bug fix: SQLite并发写入问题

Yohann0617 · Dec 21, 2024 · c67808a · c67808a
1 parent cbc8920
commit c67808a
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/src/main/java/com/yohann/ocihelper/service/impl/ISysServiceImpl.java b/src/main/java/com/yohann/ocihelper/service/impl/ISysServiceImpl.java
@@ -111,7 +111,7 @@ public String login(LoginParams params) {
     @Transactional(rollbackFor = Exception.class)
     public void updateSysCfg(UpdateSysCfgParams params) {
         kvService.remove(new LambdaQueryWrapper<OciKv>().eq(OciKv::getType, SysCfgTypeEnum.SYS_INIT_CFG.getCode()));
-        kvService.saveBatch(SysCfgEnum.getCodeListByType(SysCfgTypeEnum.SYS_INIT_CFG).parallelStream()
+        kvService.saveBatch(SysCfgEnum.getCodeListByType(SysCfgTypeEnum.SYS_INIT_CFG).stream()
                 .map(x -> {
                     OciKv ociKv = new OciKv();
                     ociKv.setId(IdUtil.getSnowflakeNextIdStr());
@@ -306,7 +306,7 @@ private String getCfgValue(SysCfgEnum sysCfgEnum) {
 
     private void cleanAndRestartTask() {
         Optional.ofNullable(createTaskService.list())
-                .filter(CollectionUtil::isNotEmpty).orElseGet(Collections::emptyList).parallelStream()
+                .filter(CollectionUtil::isNotEmpty).orElseGet(Collections::emptyList).stream()
                 .forEach(task -> {
                     if (task.getCreateNumbers() <= 0) {
                         createTaskService.removeById(task.getId());

diff --git a/src/main/java/com/yohann/ocihelper/task/OciTask.java b/src/main/java/com/yohann/ocihelper/task/OciTask.java
@@ -70,7 +70,7 @@ private void cleanLogTask() {
 
     private void cleanAndRestartTask() {
         Optional.ofNullable(createTaskService.list())
-                .filter(CollectionUtil::isNotEmpty).orElseGet(Collections::emptyList).parallelStream()
+                .filter(CollectionUtil::isNotEmpty).orElseGet(Collections::emptyList).stream()
                 .forEach(task -> {
                     if (task.getCreateNumbers() <= 0) {
                         createTaskService.removeById(task.getId());