♻️ refactor: AOP, 스케쥴러 비동기 처리 시 스레드풀을 사용하도록 개선

Author: kfdsy0103

src/main/java/org/withtime/be/withtimebe/domain/log/dateplacelog/scheduler/DatePlaceLogScheduler.java

@@ -5,6 +5,7 @@
 
 import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
 import org.springframework.cache.annotation.CacheEvict;
+import org.springframework.scheduling.annotation.Async;
 import org.springframework.scheduling.annotation.Scheduled;
 import org.springframework.stereotype.Component;
 import org.springframework.transaction.annotation.Transactional;
@@ -25,6 +26,7 @@ public class DatePlaceLogScheduler {
 	private final DatePlaceRepository datePlaceRepository;
 	private final DatePlaceLogRepository datePlaceLogRepository;
 
+	@Async("logTaskExecutor")
 	@Scheduled(cron = "${scheduler.logs.date-place.sync-cron}")
 	@Transactional(readOnly = true)
 	@CacheEvict(

src/main/java/org/withtime/be/withtimebe/domain/log/dateplacelog/service/query/DatePlaceLogQueryServiceImpl.java

@@ -24,13 +24,6 @@ public class DatePlaceLogQueryServiceImpl implements DatePlaceLogQueryService {
 	private final MongoTemplate mongoTemplate;
 
 	@Override
-	@Cacheable(
-		value = "date-place-log",
-		key = "T(java.time.LocalDate).now().getYear() + '-' + " +
-			"T(java.time.LocalDate).now().get(" + "T(java.time.temporal.WeekFields).ISO.weekOfYear()" + ") + '-' + " +
-			"T(java.time.LocalDate).now().getDayOfWeek().getValue()",
-		cacheManager = "redisCacheManager"
-	)
 	public List<DatePlaceLog> findMonthlyDatePlaceLogList() {
 
 		// 1. 추출할 필드 정의

src/main/java/org/withtime/be/withtimebe/domain/log/placecategorylog/aop/LogPlaceCategoryAspect.java

@@ -27,7 +27,7 @@ public class LogPlaceCategoryAspect {
 
 	private final RedisTemplate<String, Object> redisTemplate;
 
-	@Async
+	@Async("logTaskExecutor")
 	@AfterReturning("@annotation(org.withtime.be.withtimebe.domain.log.placecategorylog.annotation.LogPlaceCategory)")
 	public void logPlaceCategory(JoinPoint joinPoint) {
 

src/main/java/org/withtime/be/withtimebe/domain/log/placecategorylog/scheduler/PlaceCategoryLogScheduler.java

@@ -1,12 +1,10 @@
 package org.withtime.be.withtimebe.domain.log.placecategorylog.scheduler;
 
 import java.time.LocalDate;
-import java.time.LocalDateTime;
 import java.time.format.DateTimeFormatter;
 import java.util.ArrayList;
 import java.util.List;
 import java.util.Map;
-import java.util.Optional;
 import java.util.Set;
 import java.util.function.Function;
 import java.util.stream.Collectors;
@@ -15,10 +13,9 @@
 import org.springframework.cache.annotation.CacheEvict;
 import org.springframework.data.redis.core.RedisTemplate;
 import org.springframework.data.redis.core.ZSetOperations;
+import org.springframework.scheduling.annotation.Async;
 import org.springframework.scheduling.annotation.Scheduled;
 import org.springframework.stereotype.Component;
-import org.withtime.be.withtimebe.domain.date.entity.PlaceCategory;
-import org.withtime.be.withtimebe.domain.date.repository.PlaceCategoryRepository;
 import org.withtime.be.withtimebe.domain.log.placecategorylog.converter.PlaceCategoryLogConverter;
 import org.withtime.be.withtimebe.domain.log.placecategorylog.model.PlaceCategoryLog;
 import org.withtime.be.withtimebe.domain.log.placecategorylog.repository.PlaceCategoryLogRepository;
@@ -35,6 +32,7 @@ public class PlaceCategoryLogScheduler {
 	private final RedisTemplate<String, Object> redisTemplate;
 	private final PlaceCategoryLogRepository placeCategoryLogRepository;
 
+	@Async("logTaskExecutor")
 	@Scheduled(cron = "${scheduler.logs.place-category.sync-cron}")
 	@CacheEvict(
 		value = "place-category-log",

src/main/java/org/withtime/be/withtimebe/global/config/AsyncConfig.java

@@ -0,0 +1,35 @@
+package org.withtime.be.withtimebe.global.config;
+
+import java.util.concurrent.Executor;
+
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.scheduling.annotation.EnableAsync;
+import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
+
+@EnableAsync
+@Configuration
+public class AsyncConfig {
+
+	@Bean(name = "logTaskExecutor")
+	public Executor logTaskExecutor() {
+		ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
+		executor.setCorePoolSize(1);
+		executor.setMaxPoolSize(3);
+		executor.setQueueCapacity(5);
+		executor.setThreadNamePrefix("Executor-Log-");
+		executor.initialize();
+		return executor;
+	}
+
+	@Bean(name = "weatherTaskExecutor")
+	public Executor weatherTaskExecutor() {
+		ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
+		executor.setCorePoolSize(1);
+		executor.setMaxPoolSize(3);
+		executor.setQueueCapacity(5);
+		executor.setThreadNamePrefix("Executor-Weather-");
+		executor.initialize();
+		return executor;
+	}
+}