feature:seata-integration-tx-api

apache · Dec 23, 2024 · 45c5c78 · 45c5c78
1 parent 16beebf
commit 45c5c78
Show file tree

Hide file tree

Showing 3 changed files with 11 additions and 3 deletions.
diff --git a/...n-tx-api/src/main/java/org/apache/seata/integration/tx/api/fence/hook/TccHookManager.java b/...n-tx-api/src/main/java/org/apache/seata/integration/tx/api/fence/hook/TccHookManager.java
@@ -20,11 +20,14 @@
 import java.util.List;
 import java.util.concurrent.CopyOnWriteArrayList;
 
+import org.apache.seata.common.lock.ResourceLock;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
 public final class TccHookManager {
     private static final Logger LOGGER = LoggerFactory.getLogger(TccHookManager.class);
+    private static final ResourceLock LOCK = new ResourceLock();
+
 
     private TccHookManager() {
 
@@ -40,7 +43,7 @@ private TccHookManager() {
      */
     public static List<TccHook> getHooks() {
         if (CACHED_UNMODIFIABLE_HOOKS == null) {
-            synchronized (TccHookManager.class) {
+            try (ResourceLock ignored = LOCK.obtain()) {
                 if (CACHED_UNMODIFIABLE_HOOKS == null) {
                     CACHED_UNMODIFIABLE_HOOKS = Collections.unmodifiableList(TCC_HOOKS);
                 }

diff --git a/.../main/java/org/apache/seata/integration/tx/api/remoting/parser/DefaultRemotingParser.java b/.../main/java/org/apache/seata/integration/tx/api/remoting/parser/DefaultRemotingParser.java
@@ -23,6 +23,7 @@
 
 import org.apache.seata.common.exception.FrameworkException;
 import org.apache.seata.common.loader.EnhancedServiceLoader;
+import org.apache.seata.common.lock.ResourceLock;
 import org.apache.seata.common.util.CollectionUtils;
 import org.apache.seata.integration.tx.api.remoting.RemotingDesc;
 import org.apache.seata.integration.tx.api.remoting.RemotingParser;
@@ -43,6 +44,8 @@ public class DefaultRemotingParser {
      */
     protected static Map<Object, RemotingDesc> remotingServiceMap = new ConcurrentHashMap<>();
 
+    private final ResourceLock resourceLock = new ResourceLock();
+
     private static class SingletonHolder {
         private static final DefaultRemotingParser INSTANCE = new DefaultRemotingParser();
     }
@@ -79,7 +82,7 @@ protected void initRemotingParser() {
      * @param remotingParser
      */
     public boolean registerRemotingParser(RemotingParser remotingParser) {
-        synchronized (this) {
+        try (ResourceLock ignored = resourceLock.obtain()) {
             return allRemotingParsers.add(remotingParser);
         }
     }

diff --git a/integration-tx-api/src/main/java/org/apache/seata/integration/tx/api/util/ProxyUtil.java b/integration-tx-api/src/main/java/org/apache/seata/integration/tx/api/util/ProxyUtil.java
@@ -16,6 +16,7 @@
  */
 package org.apache.seata.integration.tx.api.util;
 
+import org.apache.seata.common.lock.ResourceLock;
 import org.apache.seata.integration.tx.api.interceptor.handler.DefaultInvocationHandler;
 import org.apache.seata.integration.tx.api.interceptor.handler.ProxyInvocationHandler;
 import org.apache.seata.integration.tx.api.interceptor.parser.DefaultInterfaceParser;
@@ -31,6 +32,7 @@
 public class ProxyUtil {
 
     private static final Map<Object, Object> PROXYED_SET = new HashMap<>();
+    private static final ResourceLock RESOURCE_LOCK = new ResourceLock();
 
     public static <T> T createProxy(T target) {
         return createProxy(target, target.getClass().getName());
@@ -53,7 +55,7 @@ public static <T> T createProxy(T target) {
      */
     public static <T> T createProxy(T target, String beanName) {
         try {
-            synchronized (PROXYED_SET) {
+            try (ResourceLock ignored = RESOURCE_LOCK.obtain()) {
                 if (PROXYED_SET.containsKey(target)) {
                     return (T) PROXYED_SET.get(target);
                 }