Avoid calling in the same thread

LittleCadet · Apr 27, 2021 · e8d2a47 · e8d2a47
1 parent 7381fd1
commit e8d2a47
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 5 deletions.
diff --git a/...t-starter/src/main/java/com/nepxion/discovery/agent/plugin/spring/async/WrapCallable.java b/...t-starter/src/main/java/com/nepxion/discovery/agent/plugin/spring/async/WrapCallable.java
@@ -27,13 +27,12 @@ public WrapCallable(Callable<T> callable) {
 
     @Override
     public T call() throws Exception {
-
-        //Avoid calling in the same thread.
+        // Avoid calling in the same thread
         if (asyncContext.getOriginThread().equals(Thread.currentThread())) {
             return callable.call();
         }
 
-        //Call the original method and copy some objects held by ThreadLocal.
+        // Call the original method and copy some objects held by ThreadLocal
         Object[] objects = asyncContext.getObjects();
         ThreadLocalCopier.before(objects);
         try {

diff --git a/...ain/java/com/nepxion/discovery/agent/plugin/thread/interceptor/ThreadCallInterceptor.java b/...ain/java/com/nepxion/discovery/agent/plugin/thread/interceptor/ThreadCallInterceptor.java
@@ -21,7 +21,8 @@ public static void before(Object object) {
             if (null == asyncContext) {
                 return;
             }
-            //Avoid calling in the same thread.
+
+            // Avoid calling in the same thread
             if (asyncContext.getOriginThread().equals(Thread.currentThread())) {
                 return;
             }
@@ -37,10 +38,12 @@ public static void after(Object object) {
             if (null == asyncContext) {
                 return;
             }
-            //Avoid calling in the same thread.
+
+            // Avoid calling in the same thread
             if (asyncContext.getOriginThread().equals(Thread.currentThread())) {
                 return;
             }
+
             ThreadLocalCopier.after();
         }
     }