Merge pull request #52 from Kusitms-POPTATO-DEV/refactor/async-scheduler

Refactor: scheduler async 비동기 처리

src/main/java/server/poptato/global/config/AsyncConfig.java

@@ -0,0 +1,31 @@
+package server.poptato.global.config;
+
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.scheduling.annotation.EnableAsync;
+import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
+
+import java.util.concurrent.Executor;
+import java.util.concurrent.ThreadPoolExecutor;
+
+@Configuration
+@EnableAsync
+public class AsyncConfig{
+
+    @Bean(name = "taskExecutor")
+    public Executor getAsyncExecutor() {
+        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
+
+        executor.setCorePoolSize(10);
+        executor.setMaxPoolSize(20);
+        executor.setQueueCapacity(15000);
+
+        executor.setThreadNamePrefix("Async-Executor-");
+
+        executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
+
+        executor.initialize();
+        return executor;
+    }
+}
+

src/main/java/server/poptato/todo/application/TodoScheduler.java

@@ -2,6 +2,7 @@
 
 import jakarta.transaction.Transactional;
 import lombok.RequiredArgsConstructor;
+import org.springframework.scheduling.annotation.Async;
 import org.springframework.scheduling.annotation.Scheduled;
 import org.springframework.stereotype.Service;
 import server.poptato.external.firebase.service.FCMService;
@@ -37,7 +38,7 @@ public void updateTodoType() {
         updateTodo(updatedTodoIds);
         sendDeadlineNotifications();
     }
-
+    @Async
     public void updateTodo(List<Long> updatedTodoIds) {
         Map<Long, List<Todo>> userIdAndTodaysMap = updateTodays(updatedTodoIds);
         List<Todo> yesterdayTodos = updateYesterdays(updatedTodoIds);
@@ -97,7 +98,7 @@ private void save(Map<Long, List<Todo>> userIdAndTodaysMap, List<Todo> yesterday
             todoRepository.save(todo);
         }
     }
-
+    @Async
     public void sendDeadlineNotifications() {
         List<User> users = userRepository.findAll();