springframework:async

차이

문서의 선택한 두 판 사이의 차이를 보여줍니다.

차이 보기로 링크

--- springframework:async [2020/09/24 13:29]
kwon37xi [Cached Thread Pool 효과]
+++ springframework:async [2023/01/26 10:20] (현재)
kwon37xi [ThreadPoolTaskExecutor 설정]
@@ 줄 2: / 줄 2: @@
   * [[http://www.baeldung.com/spring-async|Spring Async]]
   * [[https://docs.spring.io/spring/docs/4.1.x/javadoc-api/org/springframework/scheduling/concurrent/ThreadPoolTaskExecutor.html|ThreadPoolTaskExecutor]]로 비동기 코드 실행
+  * [[java:concurrent:executorservice|Java ExecutorService]]
+  * 비동기 작업시 [[springframework:bean_lifecycle|Spring Framework Bean Lifecycle]]에 있는 ''SmartLifeCycle''을 구현해줘야만 한다.
 ===== 설정 =====
@@ 줄 20: / 줄 22: @@
 ===== ThreadPoolTaskExecutor 설정 =====
-  * [[java:concurrent:executorservice|Java ExecutorService]] 참조
+  * [[java:concurrent:executorservice|Java ExecutorService]] 참조 Spring 의 ThreadPool
-  * wait 설정으로 서버 종료시 남은 작업을 기다릴 시간 확보
+  * wait 설정으로 서버 종료시 남은 작업을 기다릴 시간 확보해야함. 아래를 안해주면 서버가 그냥 종료 돼 버린다.
   * ''waitForTasksToCompleteOnShutdown=true''
   * ''awaitTerminationSeconds=초''
@@ 줄 27: / 줄 29: @@
   * [[https://github.com/kwon37xi/java-spring-thread-pool-test|kwon37xi/java-spring-thread-pool-test: Java와 SpringFramework 의 Thread Pool 작동 방식 테스트]]
     * fixed? cached?
+  * 서버 종료시 올바로 종료됨을 보장하려면 [[springframework:bean_lifecycle|Spring Framework Bean Lifecycle]] [[https://docs.spring.io/spring-framework/docs/current/javadoc-api/org/springframework/context/SmartLifecycle.html|SmartLifeCycle]]도 구현해야한다.
 ===== Cached Thread Pool 효과 =====
-  * corePoolSize 는 적게, maxPoolSize=corePoolSize, queueCapacity를 0으로 만들면 Cached Thread Pool 처럼 작동한다.
+  * corePoolSize 는 적게 혹은 0, maxPoolSize=''Interger.MAX_VALUE'', queueCapacity를 0으로 만들면 Cached Thread Pool 처럼 작동한다.
   * 기본 CorePoolSize 만큼 풀을 생성하고,
-  * 필요하면 쓰레드풀을 최대 MaxPoolSize 만큼 증가시키고
+  * 필요하면 쓰레드풀을 최대 maxPoolSize 만큼 증가시키고
   * 안 사용하는 시간이 KeepAliveSeconds가 지나면 쓰레드를 없앤다.
   * cachedThreadPool 은 느려지는 태스크 실행시 쓰레드 갯수가 폭증해서 시스템을 다운시킬 수도 있다.
@@ 줄 37: / 줄 41: @@
 ThreadPoolTaskExecutor threadPoolTaskExecutor = new ThreadPoolTaskExecutor();
 threadPoolTaskExecutor.setThreadNamePrefix("XXXX-");
-threadPoolTaskExecutor.setCorePoolSize(10);
+threadPoolTaskExecutor.setCorePoolSize(0);
-threadPoolTaskExecutor.setMaxPoolSize(10);
+threadPoolTaskExecutor.setMaxPoolSize(Integer.MAX_VALUE);
 threadPoolTaskExecutor.setQueueCapacity(0);
 threadPoolTaskExecutor.setKeepAliveSeconds(60);
@@ 줄 73: / 줄 77: @@
         // Right now: @Async thread context !
         // (Restore the Web thread context's MDC data)
-        MDC.setContextMap(contextMap);
+        if (contextMap != null) {
+            MDC.setContextMap(contextMap);
+        }
         runnable.run();
       } finally {

springframework/async.1600921757.txt.gz · 마지막으로 수정됨: 2020/09/24 13:29 저자 kwon37xi