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

feat[map]: fast concurrent segment lock

Browse Source
This commit is contained in:
godotg
2023-03-25 16:18:42 +08:00
parent 2b2083fe80
commit 8dfced4da1
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
protocol/src/main/java/com/zfoo/protocol/collection/concurrent/ConcurrentHashMapLongObject.java
+4 -4
View File
@@ -13,11 +13,12 @@
package com.zfoo.protocol.collection.concurrent;
import io.netty.util.collection.LongObjectHashMap;
import io.netty.util.collection.LongObjectMap;
import java.util.*;
import java.util.concurrent.locks.ReadWriteLock;
import java.util.concurrent.locks.ReentrantReadWriteLock;
import java.util.function.BiConsumer;
import java.util.function.Consumer;
/**
@@ -169,15 +170,14 @@ public class ConcurrentHashMapLongObject<V> implements Map<Long, V> {
}
}
@Override
public void forEach(BiConsumer<? super Long, ? super V> action) {
public void forEachPrimitive(Consumer<LongObjectMap.PrimitiveEntry<V>> consumer) {
for (var i = 0; i < buckets; i++) {
var readLock = locks[i].readLock();
var map = maps.get(i);
readLock.lock();
try {
for (var entry : map.entries()) {
action.accept(entry.key(), entry.value());
consumer.accept(entry);
}
} finally {
readLock.unlock();