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

锁机制调整

Browse Source
This commit is contained in:
admin
2025-03-05 18:31:27 +08:00
parent c401f882e7
commit 699a3b8214
1 changed files with 17 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files
scheduler/src/main/java/com/zfoo/scheduler/util/LazyCache.java
+17 -9
View File
@@ -8,6 +8,7 @@ import java.util.List;
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.ConcurrentMap;
import java.util.concurrent.atomic.AtomicLong;
import java.util.concurrent.locks.ReentrantReadWriteLock;
import java.util.function.BiConsumer;
/**
@@ -52,7 +53,6 @@ public class LazyCache<K, V> {
SIZE;
}
private int maximumSize;
private int backPressureSize;
private long expireAfterAccessMillis;
@@ -62,6 +62,7 @@ public class LazyCache<K, V> {
private ConcurrentMap<K, Cache<K, V>> cacheMap;
private BiConsumer<List<Cache<K, V>>, RemovalCause> removeListener = (removes, removalCause) -> {
};
private final ReentrantReadWriteLock rwLock = new ReentrantReadWriteLock();
public LazyCache(int maximumSize, long expireAfterAccessMillis, long expireCheckIntervalMillis, BiConsumer<List<Cache<K, V>>, RemovalCause> removeListener) {
AssertionUtils.ge1(maximumSize);
@@ -155,16 +156,23 @@ public class LazyCache<K, V> {
removeListener.accept(removeList, removalCause);
}
private synchronized void checkMaximumSize() {
if (cacheMap.size() > backPressureSize) {
var removeList = cacheMap.values()
.stream()
.sorted((a, b) -> Long.compare(a.expireTime, b.expireTime))
.limit(Math.max(0, cacheMap.size() - maximumSize))
.toList();
removeForCause(removeList, RemovalCause.SIZE);
private void checkMaximumSize() {
if (rwLock.writeLock().tryLock()) { // 获取写锁
try {
if (cacheMap.size() > backPressureSize) {
var removeList = cacheMap.values()
.stream()
.sorted((a, b) -> Long.compare(a.expireTime, b.expireTime))
.limit(Math.max(0, cacheMap.size() - maximumSize))
.toList();
removeForCause(removeList, RemovalCause.SIZE);
}
} finally {
rwLock.writeLock().unlock();
}
}
}
synchronized
private void checkExpire() {
var now = TimeUtils.now();