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

Merge pull request #122 from LucaLq/main

Browse Source 
feat[orm]:output stack information when concurrent writeh
This commit is contained in:
godotg
2024-07-09 14:40:07 +08:00
committed by GitHub
parent 2b7b8b52de ea7d1cf304
commit 4d01f39879
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
orm/src/main/java/com/zfoo/orm/cache/EntityCache.java
Vendored
+3 -3
View File
@@ -188,10 +188,10 @@ public class EntityCache<PK extends Comparable<PK>, E extends IEntity<PK>> imple
var pnodeThread = ThreadUtils.findThread(pnodeThreadId);
// 有并发写风险，第一次更新文档的线程和第2次更新更新文档的线程不相等
if (pnodeThread == null) {
logger.warn("[{}][id:{}] concurrent write warning, first update [threadId:{}], second update [threadId:{}]", entity.getClass().getSimpleName(), entity.id(), pnodeThreadId, currentThreadId);
logger.warn("orm concurrent write warning", new RunException("[{}][id:{}] first update [threadId:{}], second update [threadId:{}]", entity.getClass().getSimpleName(), entity.id(), pnodeThreadId, currentThreadId));
} else {
logger.warn("[{}][id:{}] concurrent write warning, first update [threadId:{}][threadName:{}], second update [threadId:{}][threadName:{}]"
, entity.getClass().getSimpleName(), entity.id(), pnodeThreadId, pnodeThread.getName(), currentThreadId, Thread.currentThread().getName());
logger.warn("orm concurrent write warning", new RunException("[{}][id:{}] first update [threadId:{}][threadName:{}], second update [threadId:{}][threadName:{}]"
, entity.getClass().getSimpleName(), entity.id(), pnodeThreadId, pnodeThread.getName(), currentThreadId, Thread.currentThread().getName()));
}
}
}