tiennm99/zfoo
1
0
Fork 0
mirror of https://github.com/tiennm99/zfoo.git synced 2026-09-04 16:17:37 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix: filter null entity

Browse Source
This commit is contained in:
godotg
2024-10-08 23:32:49 +08:00
parent f04838195b
commit a26547586f
1 changed files with 20 additions and 14 deletions
Download Patch File Download Diff File Expand all files Collapse all files
orm/src/main/java/com/zfoo/orm/cache/EntityCache.java
Vendored
+20 -14
View File
@@ -74,7 +74,12 @@ public class EntityCache<PK extends Comparable<PK>, E extends IEntity<PK>> imple
if (removalCause == LazyCache.RemovalCause.EXPLICIT) {
return;
}
EventBus.asyncExecute(clazz.hashCode(), () -> doPersist(removes.stream().map(it -> it.v.getEntity()).toList()));
var updateList = removes.stream()
.map(it -> it.v)
.filter(it -> !noNeedUpdate(it))
.map(it -> it.getEntity())
.toList();
EventBus.asyncExecute(clazz.hashCode(), () -> doPersist(updateList));
}
};
var expireCheckIntervalMillis = Math.max(3 * TimeUtils.MILLIS_PER_SECOND, entityDef.getExpireMillisecond() / 10);
@@ -220,16 +225,17 @@ public class EntityCache<PK extends Comparable<PK>, E extends IEntity<PK>> imple
@Override
public void persist(PK pk) {
var pnode = caches.get(pk);
if (pnode == null) {
return;
}
if (pnode.getModifiedTime() == pnode.getWriteToDbTime()) {
if (noNeedUpdate(pnode)) {
return;
}
pnode.resetTime(TimeUtils.currentTimeMillis());
doPersist(List.of(pnode.getEntity()));
}
private boolean noNeedUpdate(PNode<PK, E> pnode) {
return pnode == null || pnode.getEntity() == null || pnode.getModifiedTime() == pnode.getWriteToDbTime();
}
// 游戏中80%都是执行更新的操作，这样做会极大的提高更新速度
// 没有并发问题的entity指的是内部没有使用集合或者使用的集合全部支持并发操作
@@ -246,12 +252,12 @@ public class EntityCache<PK extends Comparable<PK>, E extends IEntity<PK>> imple
caches.forEach(new BiConsumer<PK, PNode<PK, E>>() {
@Override
public void accept(PK pk, PNode<PK, E> pnode) {
var entity = pnode.getEntity();
if (pnode.getModifiedTime() != pnode.getWriteToDbTime()) {
pnode.resetTime(currentTime);
var updateList = updateMap.computeIfAbsent(pnode.getThreadId(), it -> new ArrayList<>(initSize));
updateList.add(entity);
if (noNeedUpdate(pnode)) {
return;
}
pnode.resetTime(currentTime);
var updateList = updateMap.computeIfAbsent(pnode.getThreadId(), it -> new ArrayList<>(initSize));
updateList.add(pnode.getEntity());
}
});
var count = 0;
@@ -276,11 +282,11 @@ public class EntityCache<PK extends Comparable<PK>, E extends IEntity<PK>> imple
caches.forEach(new BiConsumer<PK, PNode<PK, E>>() {
@Override
public void accept(PK pk, PNode<PK, E> pnode) {
var entity = pnode.getEntity();
if (pnode.getModifiedTime() != pnode.getWriteToDbTime()) {
pnode.resetTime(currentTime);
updateList.add(entity);
if (noNeedUpdate(pnode)) {
return;
}
pnode.resetTime(currentTime);
updateList.add(pnode.getEntity());
}
});
doPersist(updateList);