tiennm99/zfoo
1
0
Fork 0
mirror of https://github.com/tiennm99/zfoo.git synced 2026-05-30 22:25:37 +00:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #135 from awakeyoyoyo/main

Browse Source 
perf[orm]: code style
This commit is contained in:
jaysunxiao
2024-10-22 21:08:11 +08:00
committed by GitHub
parent 12116091c4 c05df57821
commit 0971bc8414
1 changed files with 0 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
orm/src/main/java/com/zfoo/orm/cache/EntityCache.java
Vendored
-4
View File
@@ -243,7 +243,6 @@ public class EntityCache<PK extends Comparable<PK>, E extends IEntity<PK>> imple
if (entityDef.isThreadSafe()) {
EventBus.asyncExecute(clazz.hashCode(), () -> persistAllBlock());
} else {
var currentTime = TimeUtils.currentTimeMillis();
// key为threadId
var updateMap = new HashMap<Long, List<PNode<PK, E>>>();
var initSize = caches.size() >> 2;
@@ -253,7 +252,6 @@ public class EntityCache<PK extends Comparable<PK>, E extends IEntity<PK>> imple
if (noNeedUpdate(pnode)) {
return;
}
pnode.resetTime(currentTime);
var updateList = updateMap.computeIfAbsent(pnode.getThreadId(), it -> new ArrayList<>(initSize));
updateList.add(pnode);
}
@@ -275,7 +273,6 @@ public class EntityCache<PK extends Comparable<PK>, E extends IEntity<PK>> imple
@Override
public void persistAllBlock() {
var currentTime = TimeUtils.currentTimeMillis();
var updateList = new ArrayList<PNode<PK, E>>(caches.size());
caches.forEach(new BiConsumer<PK, PNode<PK, E>>() {
@Override
@@ -283,7 +280,6 @@ public class EntityCache<PK extends Comparable<PK>, E extends IEntity<PK>> imple
if (noNeedUpdate(pnode)) {
return;
}
pnode.resetTime(currentTime);
updateList.add(pnode);
}
});