Springboot的ThreadPoolTaskScheduler線程池輕松搞定15分鐘不操作自動取消訂單

更新時間：2025年01月10日 12:17:35 作者：rain_is_my_name

這篇文章主要介紹了Springboot的ThreadPoolTaskScheduler線程池輕松搞定15分鐘不操作自動取消訂單,本文給大家介紹的非常詳細,需要的朋友可以參考下

ThreadPoolTaskScheduler線程池實現(xiàn)15分鐘不操作自動取消訂單

概要

使用ThreadPoolTaskScheduler的schedule方法實現(xiàn)當(dāng)前操作15分鐘后執(zhí)行定時任務(wù)

1，創(chuàng)建訂單后觸發(fā)

1.1 Impl層

 private final OrderSchedulerService schedulerService;
 @Override
    @Transactional(rollbackFor = Exception.class)
    public R saveHotelOrder(HotelOrderPO po) {
        HotelOrder order = new HotelOrder();
        boolean saveOrUpdate = saveOrUpdate(order);
        // 補充自己的開發(fā)邏輯
        if(條件滿足){
        	 schedulerService.createScheduler(order.getId());
        }
        return R.data(order.getId());
    }

1.2 OrderSchedulerService（核心類）

@Slf4j
@Service
@AllArgsConstructor
public class OrderSchedulerService {
    private final HotelOrderMapper hotelOrderMapper;
    private final ThreadPoolTaskScheduler taskScheduler = new ThreadPoolTaskScheduler();
    private final ConcurrentHashMap<Long, ScheduledFuture<?>> orderTasks = new ConcurrentHashMap<>();
    // 模擬用戶新增訂單
    public void createScheduler(Long orderId) {
        taskScheduler.initialize();
        // 15分鐘后執(zhí)行
        Instant plus = Instant.now().plus(Duration.ofMinutes(15));
        ScheduledFuture<?> future = taskScheduler.schedule(() -> {
            if (isOrderActive(orderId)) {
                // 取消訂單
                HotelOrder order = hotelOrderMapper.selectById(orderId);
                order.setStatus(CommonConstant.INT_5);
                hotelOrderMapper.updateById(order);
                log.info("15分鐘未操作，自動取消訂單：{}", order.getSerialNumber());
            }
        }, plus);
        orderTasks.put(orderId, future);
    }
    // 訂單取消時，取消訂單的15分鐘定時任務(wù)
    public void cancelScheduler(Long orderId) {
        ScheduledFuture<?> future = orderTasks.get(orderId);
        if (future != null && !future.isDone()) {
            future.cancel(false);
            orderTasks.remove(orderId);
            log.info("15分鐘有支付操作，取消訂單定時任務(wù)：{}", orderId);
        }
    }
    // 檢查訂單是否仍在任務(wù)列表中（模擬訂單未刪除）
    private boolean isOrderActive(Long orderId) {
        return orderTasks.containsKey(orderId);
    }
}

2，訂單手動取消則取消該訂單對應(yīng)的定時任務(wù)

1.1 Impl層

 @Override
    public R cancelByIdForMini(Long id, String reason) {
    	// 寫自己的取消業(yè)務(wù)
        // 訂單取消時，取消訂單的15分鐘定時任務(wù)
        log.info(" 訂單取消時，取消訂單的15分鐘定時任務(wù):{}", id.toString());
        schedulerService.cancelScheduler(id);
        return R.status(true);
    }

總結(jié)

使用ThreadPoolTaskScheduler的schedule方法實現(xiàn)當(dāng)前操作15分鐘后執(zhí)行定時任務(wù)~
創(chuàng)作不易，尊重知識，轉(zhuǎn)載請附帶本文鏈接

到此這篇關(guān)于Springboot的ThreadPoolTaskScheduler線程池輕松搞定15分鐘不操作自動取消訂單的文章就介紹到這了,更多相關(guān)Springboot ThreadPoolTaskScheduler線程池內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: