专栏首页令仔很忙令仔学多线程系列(三)----每天定点执行指定任务

令仔学多线程系列(三)----每天定点执行指定任务

/**
 * 定点去发起重搜类-21点
 * Created by ling.zhang on 2017/3/1.
 */
@Component
public class AirChangeTimerManage extends TimerTask {
    private static final Logger logger= LoggerFactory.getLogger(AirChangeTimerManage.class);

    @Autowired
    PolicyRedisManage redisManage;


    //时间间隔  ms
    private static final long PERIOD_DAY = 24 * 60 * 60 * 1000;

    public AirChangeOrderLoadManage(){
        Calendar calendar=Calendar.getInstance();

        /*** 定制每日4:00执行方法 ***/
        calendar.set(Calendar.HOUR_OF_DAY,4);
        calendar.set(Calendar.MINUTE,00);
        calendar.set(Calendar.SECOND,00);

        Date date=calendar.getTime();  //第一次执行定时任务的时间

        //如果第一次执行定时任务的时间  小于 当前时间
        //此时要在第一次执行定时任务的时间加一天,以便次任务在下个时间点执行,如果不加一天,任务会立即执行。
        if (date.before(new Date())){
            date=this.addDay(date,1);
        }

        Timer timer=new Timer();
        //安排指定的任务在指定的时间开始进行重复的固定延迟执行。
        timer.schedule(this,date,PERIOD_DAY);
    }

    // 增加或减少天数
    public Date addDay(Date date, int num) {
        Calendar startDT = Calendar.getInstance();
        startDT.setTime(date);
        startDT.add(Calendar.DAY_OF_MONTH, num);
        return startDT.getTime();

    }



    @Override
    public void run(){
        try{
            //相关任务
        }catch (Exception e){
            logger.error("airchange timer error {}",e);
        }
    }
}

需要注意的一个地方,就是在AirChangeTimerManage 类中,我是每天4点定时执行任务,但是如果我在4点之后进行了重启或者发布,启动之后这个任务就会立即启动执行,这样并不是我想要的,为了,避免这种情况发生,只能判断一下,如果发布或重启服务的时间晚于定时执行任务的时间,就在此基础上加一天。

扩展

上面的这种方式还是有些局限的,如果有多个定时任务,那每个类中都要加这些代码。因为我在这用的是this。只执行当前类。

timer.schedule(this,date,PERIOD_DAY);

所以这样还是有些坑的,当然这也得看具体的情况。可以是这样的

Timer timer = new Timer();
24

25
  AirChangeTimerManage task = new AirChangeTimerManage();
26
  //安排指定的任务在指定的时间开始进行重复的固定延迟执行。
27
  timer.schedule(task,date,PERIOD_DAY);

但是在AirChangeTimerManage类里面,有下面这些代码:

 @Value("${airchangeopen}")
    String airChangeOpen;

    @Autowired
    OTAOrderFlightInfoDao flightInfoDao;

    @Autowired
    ReportDetailDao reportDetailDao;

    @Autowired
    PolicyRedisManage redisManage;

如果用new的话,这些会启动不起来的。当然如果你的任务中如果只涉及到了一些计算之类的,完全可以用另外new的方式。扩展性挺好的。就是配置一个监听器来监听定时任务。

public class AirChangeTimerManage extends TimerTask {
 private static Logger log = Logger.getLogger(NFDFlightDataTimerTask.class);

 @Override
 public void run() {
  try {
   //在这里写你要执行的内容
  } catch (Exception e) {
   log.info("-------------解析信息发生异常--------------");
  }
 }
}

public class AirChangeListener implements ServletContextListener {

 public void contextInitialized(ServletContextEvent event) {
  new AirChangeTimerManage();
 }

 public void contextDestroyed(ServletContextEvent event) {
 }
}

然后再web.xml中配置监听器

<listener>

 <listener-class>

  com.listener.NFDFlightDataTaskListener

 </listener-class>

</listener>

这样的话,多个定时任务就不会出现那么多的重复代码了。 如果有什么不足之处,还望各位同志们多多指正。

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

我来说两句

0 条评论
登录 后参与评论

相关文章

  • 三层架构(一)——什么是三层架构?

    三层架构(3-tier architecture) 通常意义上的三层架构就是将整个业务应用划分为:表现层(UI)、业务逻辑层(BLL)、数据访问层(DAL)。...

    令仔很忙
  • 千里之堤,毁于蚁穴----考试系统

       千里之堤,毁于蚁穴,做项目的过程中可能会涉及到成千上万行的代码,在开发的过程中,一定要注意一些细节上的问题,这不是一篇技术性很高的文章,主要是思想。

    令仔很忙
  • 学生信息管理系统问题集锦

     1)、数据库的ODBC配置出现错误,没有配置好,与数据库的连接没有连接好,就会出现这样的问题

    令仔很忙
  • 如何有效报告 bug

    这也是「技术支持」被视为一个可怕工作的原因。然而,并不是所有的 bug 报告都是让人不愉快的。我一直在没赚钱的时候维护开源软件,有时候会收到一些非常清晰的、有帮...

    developerHaoz
  • 时代新宠儿——HEIF图像格式:节省50%空间

    HEIF全称High Efficiency Image File Format(高效图像文件格式),是一种高效的图片封装格式,文件名通常为.heif或者.hei...

    云存储
  • 中国科学院王颖:论人工智能与艺术 | CCAI 演讲实录

    用户1737318
  • 【人工智能报告】深度分析中国467家AI企业、636起投资事件

    本次报告主要讲述了人工智能的崛起、产业结构图谱、全球大公司布局以及最为重要的创投数据盘点四大部分。 以下是这份报告的重要数据: 据 IT 桔子历史数据统计,目前...

    钱塘数据
  • 11 月全国程序员平均工资出炉

    工资好像又降低了,吓得我瑟瑟发抖。《权力的游戏》里面的一句话又回荡在我的耳边:winter is coming。

    吾非同
  • 11 月全国程序员平均工资出炉

    工资好像又降低了,吓得我瑟瑟发抖。《权力的游戏》里面的一句话又回荡在我的耳边:winter is coming。

    王小婷
  • 为什么说Java中只有值传递?

    相信我,当你正在看这篇文章的时,说明你对值传递和引用传递的理解大概率是错误的。如果你理解的是正确的,你应该也不会来看这篇文章。

    诺浅

扫码关注云+社区

领取腾讯云代金券