将实体发生改变清理缓存的动作由并行改回了串行

jovezhao · Sep 7, 2020 · 63d1d09 · 63d1d09
1 parent 4755da9
commit 63d1d09
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/nest-ddd/src/main/java/com/zhaofujun/nest/context/appservice/UnitOfWork.java b/nest-ddd/src/main/java/com/zhaofujun/nest/context/appservice/UnitOfWork.java
@@ -37,6 +37,7 @@ public <T extends BaseEntity> T getEntity(Class tClass, Identifier identifier) {
         Entity entity = entities
                 .stream()
                 .filter(p -> identifier.equals(p.getId()) && tClass.isInstance(p))
+                .filter(p->!p.is__deleted())
                 .findFirst()
                 .orElse(null);
         return (T) entity;
@@ -69,7 +70,7 @@ private void commitEntity() {
                         // s.parallelStream().forEach(ss -> cacheClient.remove(EntityCacheUtils.getCacheKey(ss)));
                 }
                 entityNotify(r, s);
-                s.parallelStream().forEach(ss -> cacheClient.remove(EntityCacheUtils.getCacheKey(ss)));
+                s.forEach(ss -> cacheClient.remove(EntityCacheUtils.getCacheKey(ss)));
             });
         });