test async

community-service/src/main/java/com/tanpu/community/config/ExecutorConfig.java

+package com.tanpu.community.config;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.cloud.sleuth.instrument.async.LazyTraceAsyncTaskExecutor;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.core.task.AsyncTaskExecutor;
+import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
+import org.springframework.stereotype.Component;
+
+import java.util.concurrent.Executor;
+import java.util.concurrent.ThreadPoolExecutor;
+
+@Component
+@Configuration
+public class ExecutorConfig {
+
+    @Bean
+    public AsyncTaskExecutor asyncTaskExecutor() {
+        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
+        executor.setCorePoolSize(2);
+        executor.setMaxPoolSize(5);
+        executor.setQueueCapacity(50);
+        executor.setKeepAliveSeconds(10);
+
+        // rejection-policy：当pool已经达到max size的时候，如何处理新任务
+        // CALLER_RUNS：不在新线程中执行任务，而是有调用者所在的线程来执行
+        executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
+        executor.initialize();
+        return executor;
+    }
+}

community-service/src/main/java/com/tanpu/community/service/TraceTestService.java

@@ -5,14 +5,15 @@ import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.BeanFactory;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.cloud.sleuth.instrument.async.LazyTraceAsyncTaskExecutor;
+import org.springframework.scheduling.annotation.Async;
 import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
 import org.springframework.stereotype.Service;
 
 import javax.annotation.PostConstruct;
 import java.util.concurrent.atomic.AtomicInteger;
 
-@Service
-@Slf4j
+//@Service
+//@Slf4j
 public class TraceTestService {
 
     @Autowired
@@ -36,6 +37,17 @@ public class TraceTestService {
         count = new AtomicInteger(0);
     }
 
+    @Async("asyncTaskExecutor")
+    public void testTraceIdAsync(int i) {
+        try {
+            Thread.sleep(1000);
+            log.info("async count is " + i);
+        } catch (Exception e) {
+
+        }
+
+    }
+
     public void testTraceId() {
         Integer c = count.incrementAndGet();
         log.info("parent count is " + c);
@@ -55,6 +67,5 @@ public class TraceTestService {
                 }
             });
         }
-
     }
 }