延迟队列与轮询业务扫描_大数据培训

@Scheduled(cron = "0/30 * * * * ?")
public void checkUnpaidOrder() {
    System.out.println("开始检查未付款单据 = ");
    Long beginTime=System.currentTimeMillis();
    List<OrderInfo> unpaidOrderList = orderService.getUnpaidOrderList();
    for (OrderInfo orderInfo : unpaidOrderList) {
        orderService.checkExpireOrder(orderInfo);
    }
    Long costtime=System.currentTimeMillis()-beginTime;
    System.out.println("开始检查完毕未付款单据 = 共消耗"+costtime);
}

public  void  checkExpireOrder(OrderInfo orderInfo  )   {
 
            updateProcessStatus(orderInfo.getId(), ProcessStatus.CLOSED);
            paymentService.closePayment(orderInfo.getId());
 

    return ;

}

@Configuration
@EnableAsync
public class AsyncTaskConfig implements AsyncConfigurer {
    @Override
    @Bean
    public Executor getAsyncExecutor() {
        ThreadPoolTaskExecutor threadPoolTaskExecutor=new ThreadPoolTaskExecutor();
        threadPoolTaskExecutor.setCorePoolSize(10);    //线程数
        threadPoolTaskExecutor.setQueueCapacity(100);    //等待队列容量 ，线程数不够任务会等待
        threadPoolTaskExecutor.setMaxPoolSize(50);     // 最大线程数，等待数不够会增加线程数，直到达此上线  超过这个范围会抛异常
        threadPoolTaskExecutor.initialize();
        return threadPoolTaskExecutor;

    }

    @Override
    @Bean
    public AsyncUncaughtExceptionHandler getAsyncUncaughtExceptionHandler() {
        return null;
    }
}

@Async

public  void  checkExpireOrder(OrderInfo orderInfo  )   {
    Date expireDate= DateUtil.addDays(orderInfo.getCreateTime(),1) ;
        if (new Date().after(expireDate)){
            updateProcessStatus(orderInfo.getId(), ProcessStatus.CLOSED);
            paymentService.closePayment(orderInfo.getId());
        }
    return ;
}