log

brave-spring-boot-starter/src/main/java/cn/quantgroup/tech/brave/service/impl/ITechExecutorServiceBuilderNoTrace.java → brave-spring-boot-starter/src/main/java/cn/quantgroup/tech/brave/service/impl/TechExecutorServiceBuilderNoTrace.java

 package cn.quantgroup.tech.brave.service.impl;
 
 import cn.quantgroup.tech.brave.service.ITechExecutorServiceBuilder;
+import lombok.extern.slf4j.Slf4j;
 import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
 
 import java.util.concurrent.ExecutorService;
@@ -12,13 +13,17 @@ import java.util.concurrent.RejectedExecutionHandler;
  *
  * @author: yangrui
  */
-public class ITechExecutorServiceBuilderNoTrace implements ITechExecutorServiceBuilder {
+@Slf4j
+public class TechExecutorServiceBuilderNoTrace implements ITechExecutorServiceBuilder {
     @Override
     public ExecutorService buildExecutorService(int corePoolSize,
                                                 int maxPoolSize,
                                                 int queueCapacity,
                                                 String threadNamePrefix,
                                                 RejectedExecutionHandler rejectedExecutionHandler) {
+        log.info("构建TechExecutorServiceBuilderNoTrace, corePoolSize = 【{}】, maxPoolSize = 【{}】, queueCapacity = 【{}】, " +
+                        "threadNamePrefix = 【{}】, rejectedExecutionHandler = 【{}】", corePoolSize, maxPoolSize, queueCapacity,
+                threadNamePrefix, rejectedExecutionHandler);
         ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
         executor.setCorePoolSize(corePoolSize);
         executor.setMaxPoolSize(maxPoolSize);

brave-spring-boot-starter/src/main/java/cn/quantgroup/tech/brave/service/impl/ITechExecutorServiceBuilderTrace.java → brave-spring-boot-starter/src/main/java/cn/quantgroup/tech/brave/service/impl/TechExecutorServiceBuilderTrace.java

@@ -3,6 +3,7 @@ package cn.quantgroup.tech.brave.service.impl;
 import brave.propagation.CurrentTraceContext;
 import cn.quantgroup.tech.brave.service.ITechExecutorServiceBuilder;
 import cn.quantgroup.tech.brave.slf4j.MDCCurrentTraceContext;
+import lombok.extern.slf4j.Slf4j;
 import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
 
 import java.util.concurrent.ExecutorService;
@@ -14,13 +15,17 @@ import java.util.concurrent.RejectedExecutionHandler;
  *
  * @author: yangrui
  */
-public class ITechExecutorServiceBuilderTrace implements ITechExecutorServiceBuilder {
+@Slf4j
+public class TechExecutorServiceBuilderTrace implements ITechExecutorServiceBuilder {
     @Override
     public ExecutorService buildExecutorService(int corePoolSize,
                                                 int maxPoolSize,
                                                 int queueCapacity,
                                                 String threadNamePrefix,
                                                 RejectedExecutionHandler rejectedExecutionHandler) {
+        log.info("构建TechExecutorServiceBuilderTrace, corePoolSize = 【{}】, maxPoolSize = 【{}】, queueCapacity = 【{}】, " +
+                "threadNamePrefix = 【{}】, rejectedExecutionHandler = 【{}】", corePoolSize, maxPoolSize, queueCapacity,
+                threadNamePrefix, rejectedExecutionHandler);
         ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
         executor.setCorePoolSize(corePoolSize);
         executor.setMaxPoolSize(maxPoolSize);