root
/
Sentinel
mirror of https://github.com/alibaba/Sentinel.git
1
0
Fork 0
Code Issues Actions 1 Packages Projects Releases Wiki Activity

issue #3513

This commit is contained in:
tangjie 2025-04-12 00:07:32 +08:00
parent 32ec1965bf
commit 0f6946b3b2
1 changed files with 11 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
sentinel-core/src/main/java/com/alibaba/csp/sentinel/CtSph.java
View File

@ -48,11 +48,9 @@ public class CtSph implements Sph {
* Same resource({@link ResourceWrapper#equals(Object)}) will share the same * Same resource({@link ResourceWrapper#equals(Object)}) will share the same
* {@link ProcessorSlotChain}, no matter in which {@link Context}. * {@link ProcessorSlotChain}, no matter in which {@link Context}.
*/ */
private static Map<ResourceWrapper, ProcessorSlotChain> chainMap private static final Map<ResourceWrapper, ProcessorSlotChain> CHAIN_MAP
= new HashMap<ResourceWrapper, ProcessorSlotChain>(); = new HashMap<ResourceWrapper, ProcessorSlotChain>();
private static final Object LOCK = new Object();
private AsyncEntry asyncEntryWithNoChain(ResourceWrapper resourceWrapper, Context context) { private AsyncEntry asyncEntryWithNoChain(ResourceWrapper resourceWrapper, Context context) {
AsyncEntry entry = new AsyncEntry(resourceWrapper, null, context); AsyncEntry entry = new AsyncEntry(resourceWrapper, null, context);
entry.initAsyncContext(); entry.initAsyncContext();
@ -192,18 +190,18 @@ public class CtSph implements Sph {
* @return {@link ProcessorSlotChain} of the resource * @return {@link ProcessorSlotChain} of the resource
*/ */
ProcessorSlot<Object> lookProcessChain(ResourceWrapper resourceWrapper) { ProcessorSlot<Object> lookProcessChain(ResourceWrapper resourceWrapper) {
ProcessorSlotChain chain = chainMap.get(resourceWrapper); ProcessorSlotChain chain = CHAIN_MAP.get(resourceWrapper);
if (chain == null) { if (chain == null) {
synchronized (LOCK) { synchronized (CHAIN_MAP) {
chain = chainMap.get(resourceWrapper); chain = CHAIN_MAP.get(resourceWrapper);
if (chain == null) { if (chain == null) {
// Entry size limit. // Entry size limit.
if (chainMap.size() >= Constants.MAX_SLOT_CHAIN_SIZE) { if (CHAIN_MAP.size() >= Constants.MAX_SLOT_CHAIN_SIZE) {
return null; return null;
} }
chain = SlotChainProvider.newSlotChain(); chain = SlotChainProvider.newSlotChain();
chainMap.put(resourceWrapper, chain); CHAIN_MAP.put(resourceWrapper, chain);
} }
} }
} }
@ -217,7 +215,9 @@ public class CtSph implements Sph {
* @since 0.2.0 * @since 0.2.0
*/ */
public static int entrySize() { public static int entrySize() {
return chainMap.size(); synchronized (CHAIN_MAP){
return CHAIN_MAP.size();
}
} }
/** /**
@ -226,7 +226,7 @@ public class CtSph implements Sph {
* @since 0.2.0 * @since 0.2.0
*/ */
static void resetChainMap() { static void resetChainMap() {
chainMap.clear(); CHAIN_MAP.clear();
} }
/** /**
@ -235,7 +235,7 @@ public class CtSph implements Sph {
* @since 0.2.0 * @since 0.2.0
*/ */
static Map<ResourceWrapper, ProcessorSlotChain> getChainMap() { static Map<ResourceWrapper, ProcessorSlotChain> getChainMap() {
return chainMap; return CHAIN_MAP;
} }
/** /**