@Component
@Slf4j
@Async
public class ThreadSaveDigCategory {private static final int BATCH_COUTN = 1000;@Autowiredprivate Mapper mapper;public Future<Boolean> saveDigCategoryDatas(List<DigCategoryData> digCategoryDataList){//开始计时long startTime = System.currentTimeMillis();// mapper.saveDigCategoryData(digCategoryDataList);//数据分批处理List<List<DigCategoryData>> batchList = BathProcessUtil.batchList(digCategoryDataList, BATCH_COUTN);for (List<DigCategoryData> batch : batchList){mapper.saveDigCategoryData(batch);}//endTimelong endTime = System.currentTimeMillis();Calendar calendar = Calendar.getInstance();calendar.setTimeInMillis(endTime-startTime);log.info("耗时: " + calendar.get(Calendar.MINUTE) + "分 " + calendar.get(Calendar.SECOND) + "秒 " +calendar.get(Calendar.MILLISECOND) + " 微秒" + "-" + "数据保存成功");return new AsyncResult<>(true);}
}