diff --git a/pom.xml b/pom.xml index 898cd30..31d0ed7 100644 --- a/pom.xml +++ b/pom.xml @@ -5,7 +5,7 @@ org.springframework.boot spring-boot-starter-parent - 3.1.4 + 3.3.5 com.ycwl @@ -100,7 +100,7 @@ com.baomidou - mybatis-plus-boot-starter + mybatis-plus-spring-boot3-starter 3.5.5 diff --git a/src/main/java/com/ycwl/basic/service/mobile/impl/WxPayServiceImpl.java b/src/main/java/com/ycwl/basic/service/mobile/impl/WxPayServiceImpl.java index 3580a2e..0750266 100644 --- a/src/main/java/com/ycwl/basic/service/mobile/impl/WxPayServiceImpl.java +++ b/src/main/java/com/ycwl/basic/service/mobile/impl/WxPayServiceImpl.java @@ -96,7 +96,7 @@ public class WxPayServiceImpl implements WxPayService { log.info("[微信支付]parse = {}", callbackResponse); // 更新订单信息 - new Thread(() -> { + Thread.ofVirtual().start(() -> { long orderId = Long.parseLong(callbackResponse.getOrderNo()); if (callbackResponse.isPay()) { orderBiz.paidOrder(orderId); @@ -105,7 +105,7 @@ public class WxPayServiceImpl implements WxPayService { } else if (callbackResponse.isRefund()) { orderBiz.refundOrder(orderId); } - }).start(); + }); } catch (Exception e) { throw new AppException(BizCodeEnum.ADVANCE_PAYMENT_CALLBACK_FAILED, e.toString()); } diff --git a/src/main/java/com/ycwl/basic/service/pc/impl/FaceServiceImpl.java b/src/main/java/com/ycwl/basic/service/pc/impl/FaceServiceImpl.java index 9aee759..d5dc7d6 100644 --- a/src/main/java/com/ycwl/basic/service/pc/impl/FaceServiceImpl.java +++ b/src/main/java/com/ycwl/basic/service/pc/impl/FaceServiceImpl.java @@ -314,12 +314,12 @@ public class FaceServiceImpl implements FaceService { FaceEntity face = faceRepository.getFace(faceId); faceMapper.deleteById(faceId); faceRepository.clearFaceCache(faceId); - new Thread(() -> { + Thread.ofVirtual().start(() -> { sourceMapper.deleteNotBuyFaceRelation(face.getMemberId(), faceId); videoMapper.deleteNotBuyFaceRelations(face.getMemberId(), faceId); IFaceBodyAdapter adapter = scenicService.getScenicFaceBodyAdapter(face.getScenicId()); adapter.deleteFace(USER_FACE_DB_NAME+face.getScenicId().toString(), faceId.toString()); - }).start(); + }); return ApiResponse.success("删除成功"); } diff --git a/src/main/java/com/ycwl/basic/service/pc/impl/ScenicServiceImpl.java b/src/main/java/com/ycwl/basic/service/pc/impl/ScenicServiceImpl.java index 8f0d5e2..6f44804 100644 --- a/src/main/java/com/ycwl/basic/service/pc/impl/ScenicServiceImpl.java +++ b/src/main/java/com/ycwl/basic/service/pc/impl/ScenicServiceImpl.java @@ -100,10 +100,10 @@ public class ScenicServiceImpl implements ScenicService { if (i > 0) { scenicAccountMapper.deleteByScenicId(id); IFaceBodyAdapter adapter = getScenicFaceBodyAdapter(id); - (new Thread(() -> { + Thread.ofVirtual().start(() -> { adapter.deleteFaceDb(id.toString()); adapter.deleteFaceDb(USER_FACE_DB_NAME + id); - })).start(); + }); scenicMapper.deleteConfigByScenicId(id); scenicRepository.clearCache(id); scenicFaceBodyAdapterMap.remove(id); diff --git a/src/main/java/com/ycwl/basic/service/task/impl/TaskTaskServiceImpl.java b/src/main/java/com/ycwl/basic/service/task/impl/TaskTaskServiceImpl.java index 9b8659f..fa2d9cb 100644 --- a/src/main/java/com/ycwl/basic/service/task/impl/TaskTaskServiceImpl.java +++ b/src/main/java/com/ycwl/basic/service/task/impl/TaskTaskServiceImpl.java @@ -610,7 +610,7 @@ public class TaskTaskServiceImpl implements TaskService { } } videoMapper.updateRelationWhenTaskSuccess(taskId, video.getId(), isBuy); - new Thread(() -> sendVideoGeneratedServiceNotification(taskId)).start(); + Thread.ofVirtual().start(() -> sendVideoGeneratedServiceNotification(taskId)); } @Override diff --git a/src/main/java/com/ycwl/basic/task/VideoPieceGetter.java b/src/main/java/com/ycwl/basic/task/VideoPieceGetter.java index af8cdb2..7051a77 100644 --- a/src/main/java/com/ycwl/basic/task/VideoPieceGetter.java +++ b/src/main/java/com/ycwl/basic/task/VideoPieceGetter.java @@ -103,13 +103,13 @@ public class VideoPieceGetter { return; } log.info("poll task: {}/{}", task, queue.size()); - new Thread(() -> { + Thread.ofVirtual().start(() -> { try { runTask(task); } catch (Exception e) { log.error("run task error", e); } - }).start(); + }); } private void runTask(Task task) { diff --git a/src/main/resources/application-dev.yml b/src/main/resources/application-dev.yml index 0756bce..3d35ac8 100644 --- a/src/main/resources/application-dev.yml +++ b/src/main/resources/application-dev.yml @@ -31,6 +31,9 @@ spring: multipart: max-file-size: 500MB max-request-size: 500MB + threads: + virtual: + enabled: true web: resources: static-locations: classpath:/META-INF/resources/,classpath:/resources/,classpath:/static/,classpath:/public/ diff --git a/src/main/resources/application-prod.yml b/src/main/resources/application-prod.yml index 38e5f62..b962c7f 100644 --- a/src/main/resources/application-prod.yml +++ b/src/main/resources/application-prod.yml @@ -35,6 +35,9 @@ spring: multipart: max-file-size: 500MB max-request-size: 500MB + threads: + virtual: + enabled: true web: resources: static-locations: classpath:/META-INF/resources/,classpath:/resources/,classpath:/static/,classpath:/public/