还是用单线程 多线程会重复插入

src/main/java/com/ylcm/sys/controller/AdTheatreController.java

@@ -33,6 +33,7 @@ import javax.annotation.Resource;
 import javax.servlet.http.HttpServletRequest;
 import javax.servlet.http.HttpServletResponse;
 import java.util.ArrayList;
+import java.util.Comparator;
 import java.util.List;
 import java.util.concurrent.CompletableFuture;
 
@@ -61,7 +62,7 @@ public class AdTheatreController extends BaseController{
 	@Resource
 	private AdTheatreTvStatService adTheatreTvStatService;
 	@Resource
-	private TaskExecutor taskExecutor;
+	private TaskExecutor batchExecutor;
 
 	/**
 	 * to 列表页面
@@ -257,11 +258,11 @@ public class AdTheatreController extends BaseController{
 			// 入库
 			List<AdTheatre> adTheatres = adTheatreService.batchAdd(list, tvList);
 
+
             //同步统计数据
-			CompletableFuture[] completableFutures = adTheatres.stream().map(x -> CompletableFuture.runAsync(() -> {
-				adTheatreTvStatService.saveStatByTheatreTv(x);
-			}, taskExecutor)).toArray(CompletableFuture[]::new);
-			CompletableFuture.allOf(completableFutures).join();
+			for (AdTheatre adTheatre:adTheatres) {
+				adTheatreTvStatService.saveStatByTheatreTv(adTheatre);
+			}
 
 			// 判断执行结果
 			if (adTheatres != null) {

src/main/java/com/ylcm/sys/service/impl/AdTheatreTvStatServiceImpl.java

@@ -245,10 +245,7 @@ public class AdTheatreTvStatServiceImpl extends ServiceImpl<AdTheatreTvStatMappe
 		}
 
 
-		long start = System.currentTimeMillis();
 		List<AdTheatre> adTheatres = adTheatreMapper.selectList(queryWrapper);
-		long end = System.currentTimeMillis();
-		log.info("list 耗时, {} ", end - start);
 
 		if (CollectionUtils.isEmpty(adTheatres)) {
 			log.info("AdTheatre数据为空，删掉, {}, {}", queryWrapper.getCustomSqlSegment(), queryWrapper.getParamNameValuePairs());
@@ -302,10 +299,7 @@ public class AdTheatreTvStatServiceImpl extends ServiceImpl<AdTheatreTvStatMappe
 			adTheatreTvStat.setTvNum(total);
 			adTheatreTvStat.setTvNumD(total_d);
 
-			start = System.currentTimeMillis();
 			saveOrUpd(adTheatreTvStat);
-			end = System.currentTimeMillis();
-			log.info("save 耗时, {} ", end - start);
 
 		}
 	}

src/main/resource/applicationContext-plugin.xml

@@ -26,4 +26,20 @@
 		</property>
 	</bean>
 
+
+	<bean id="batchExecutor" class="org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor">
+		<!-- 线程池维护线程的最少数量 -->
+		<property name="corePoolSize" value="2" />
+		<!-- 允许的空闲时间 -->
+		<property name="keepAliveSeconds" value="200" />
+		<!-- 线程池维护线程的最大数量 -->
+		<property name="maxPoolSize" value="4" />
+		<!-- 缓存队列 -->
+		<property name="queueCapacity" value="4" />
+		<!-- 对拒绝task的处理策略 -->
+		<property name="rejectedExecutionHandler">
+			<bean class="java.util.concurrent.ThreadPoolExecutor$CallerRunsPolicy"/>
+		</property>
+	</bean>
+
 </beans>