Drew 6 anni fa
parent
commit
ebd45f12e4

+ 2 - 0
src/main/java/com/izouma/ticketExchange/Application.java

@@ -7,6 +7,7 @@ import org.springframework.data.jpa.repository.config.EnableJpaAuditing;
 import org.springframework.data.jpa.repository.config.EnableJpaRepositories;
 import org.springframework.data.redis.repository.configuration.EnableRedisRepositories;
 import org.springframework.retry.annotation.EnableRetry;
+import org.springframework.scheduling.annotation.EnableAsync;
 import org.springframework.security.config.annotation.method.configuration.EnableGlobalMethodSecurity;
 import springfox.documentation.swagger2.annotations.EnableSwagger2;
 
@@ -17,6 +18,7 @@ import springfox.documentation.swagger2.annotations.EnableSwagger2;
 @EnableRedisRepositories
 @EnableGlobalMethodSecurity(prePostEnabled = true, proxyTargetClass = true)
 @EnableRetry
+@EnableAsync
 public class Application {
 
     public static void main(String[] args) {

+ 7 - 3
src/main/java/com/izouma/ticketExchange/service/SyncService.java

@@ -19,6 +19,7 @@ import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.lang3.StringUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Value;
+import org.springframework.scheduling.annotation.Async;
 import org.springframework.stereotype.Service;
 
 import java.math.BigDecimal;
@@ -156,10 +157,13 @@ public class SyncService {
                     schedule.setShowDate(DateTimeUtils.toLocalDate(s.getShowDate(), "yyyy-MM-dd"));
                 }
                 scheduleList.add(schedule);
-                new Thread(() -> {
-                    scheduleRepo.saveAll(scheduleList);
-                }).start();
+                saveSchedule(scheduleList);
             });
         });
     }
+
+    @Async
+    public void saveSchedule(List<Schedule> list) {
+        scheduleRepo.saveAll(list);
+    }
 }