chore[cache]: simplify code

zfoo-project · Aug 26, 2024 · da8e2f6 · da8e2f6
1 parent 353914d
commit da8e2f6
Showing 1 changed file with 5 additions and 8 deletions.
diff --git a/orm/src/main/java/com/zfoo/orm/cache/EntityCache.java b/orm/src/main/java/com/zfoo/orm/cache/EntityCache.java
@@ -179,23 +179,20 @@ private PNode<PK, E> fetchCachePnode(E entity, boolean safe) {
     @Override
     public E get(PK pk) {
         PNode<PK, E> cachePnode = caches.get(pk);
-        if (cachePnode == null) {
-            return null;
-        }
-        return cachePnode.getEntity();
+        return cachePnode == null ? null : cachePnode.getEntity();
     }
 
     @Override
     public void update(E entity) {
         var cachePnode = fetchCachePnode(entity, true);
-        // 加100以防止，立刻加载并且立刻修改数据的情况发生时，服务器取到的时间戳相同
-        cachePnode.setModifiedTime(TimeUtils.now() + 100);
+        // 加128以防止，立刻加载并且立刻修改数据的情况发生时，服务器取到的时间戳相同
+        cachePnode.setModifiedTime(TimeUtils.now() + 128);
     }
 
     @Override
     public void updateUnsafe(E entity) {
         var cachePnode = fetchCachePnode(entity, false);
-        cachePnode.setModifiedTime(TimeUtils.now() + 100);
+        cachePnode.setModifiedTime(TimeUtils.now() + 128);
     }
 
     @Override
@@ -266,7 +263,7 @@ public void accept(PK pk, PNode<PK, E> pnode) {
                     EventBus.asyncExecute(clazz.hashCode(), () -> doPersist(updateList));
                 } else {
                     // 使用scheduler均匀的分配入库的时间点，减少数据库的并发写入压力
-                    SchedulerBus.schedule(() -> executor.execute(() -> doPersist(updateList)), count++ * 100L, TimeUnit.MILLISECONDS);
+                    SchedulerBus.schedule(() -> executor.execute(() -> doPersist(updateList)), count++ * 128L, TimeUnit.MILLISECONDS);
                 }
             }
         }