本篇文章给大家谈谈计算何时执行cron作业，然后下次执行，以及根据cron表达式计算上一次次执行时间的知识点，同时本文还将给你拓展1个30任务的Cron作业30个Cron作业每个执行1个任务、AWSG

本篇文章给大家谈谈计算何时执行cron作业，然后下次执行，以及根据cron表达式计算上一次次执行时间的知识点，同时本文还将给你拓展1个30任务的Cron作业30个Cron作业每个执行1个任务、AWS Glue - 如果行号存在差异，我可以先编写脚本来比较 2 个数据库，然后再执行 cron 作业吗？、crontab 执行过慢，上次未执行完，下次就来了，加锁处理、crontab定时执行c二进制文件问题等相关知识，希望对各位有所帮助，不要忘了收藏本站喔。

• 计算何时执行cron作业，然后下次执行（根据cron表达式计算上一次次执行时间）
• 1个30任务的Cron作业30个Cron作业每个执行1个任务
• AWS Glue - 如果行号存在差异，我可以先编写脚本来比较 2 个数据库，然后再执行 cron 作业吗？
• crontab 执行过慢，上次未执行完，下次就来了，加锁处理
• crontab定时执行c二进制文件问题

计算何时执行cron作业，然后下次执行（根据cron表达式计算上一次次执行时间）

我有一个时间表“时间定义”

1 * * * * (every hour at xx:01)2 5 * * * (every day at 05:02)0 4 3 * * (every third day of the month at 04:00)* 2 * * 5 (every minute between 02:00 and 02:59 on fridays)

而且我有一个Unix时间戳。

有什么明显的方法可以找到（计算）下一次（在给定的时间戳之后）要执行的作业？

我正在使用PHP，但是问题应该与语言无关。

[更新]

类“ PHP Cron Parser
”（由Ray推荐）将计算应该执行CRON作业的最后时间，而不是下一次。

使其变得更容易：在我的情况下，cron时间参数仅是绝对值，单个数字或“ *”。没有时间范围，也没有“ * / 5”间隔。

答案1

基本上，这与检查当前时间是否符合条件相反。所以像这样：

//Totaly made up languagenext = getTimeNow();next.addMinutes(1) //so that next is never nowdone = false;while (!done) {  if (cron.minute != ''*'' && next.minute != cron.minute) {    if (next.minute > cron.minute) {      next.addHours(1);    }    next.minute = cron.minute;  }  if (cron.hour != ''*'' && next.hour != cron.hour) {    if (next.hour > cron.hour) {      next.hour = cron.hour;      next.addDays(1);      next.minute = 0;      continue;    }    next.hour = cron.hour;    next.minute = 0;    continue;  }  if (cron.weekday != ''*'' && next.weekday != cron.weekday) {    deltaDays = cron.weekday - next.weekday //assume weekday is 0=sun, 1 ... 6=sat    if (deltaDays < 0) { deltaDays+=7; }    next.addDays(deltaDays);    next.hour = 0;    next.minute = 0;    continue;  }  if (cron.day != ''*'' && next.day != cron.day) {    if (next.day > cron.day || !next.month.hasDay(cron.day)) {      next.addMonths(1);      next.day = 1; //assume days 1..31      next.hour = 0;      next.minute = 0;      continue;    }    next.day = cron.day    next.hour = 0;    next.minute = 0;    continue;  }  if (cron.month != ''*'' && next.month != cron.month) {    if (next.month > cron.month) {      next.addMonths(12-next.month+cron.month)      next.day = 1; //assume days 1..31      next.hour = 0;      next.minute = 0;      continue;    }    next.month = cron.month;    next.day = 1;    next.hour = 0;    next.minute = 0;    continue;  }  done = true;}

我可能已经写了一些倒退。如果不是在每个主记录中都只是将当前时间等级加1，然后将较小的时间等级设置为0，然后继续，则它可能会更短，而不是在每个主要项目中都执行大于检查的步骤。但是，那么您将循环更多。像这样：

//Shorter more loopy versionnext = getTimeNow().addMinutes(1);while (true) {  if (cron.month != ''*'' && next.month != cron.month) {    next.addMonths(1);    next.day = 1;    next.hour = 0;    next.minute = 0;    continue;  }  if (cron.day != ''*'' && next.day != cron.day) {    next.addDays(1);    next.hour = 0;    next.minute = 0;    continue;  }  if (cron.weekday != ''*'' && next.weekday != cron.weekday) {    next.addDays(1);    next.hour = 0;    next.minute = 0;    continue;  }  if (cron.hour != ''*'' && next.hour != cron.hour) {    next.addHours(1);    next.minute = 0;    continue;  }  if (cron.minute != ''*'' && next.minute != cron.minute) {    next.addMinutes(1);    continue;  }  break;}

1个30任务的Cron作业30个Cron作业每个执行1个任务

#!/usr/bin/env python
# -*- coding: utf-8 -*-
import json
import logging
import os
import time
from os.path import dirname, abspath

import requests

PROJECT_DIR = dirname(dirname(dirname(abspath(__file__))))
print PROJECT_DIR
import sys

sys.path.insert(0, PROJECT_DIR)

if len(sys.argv) > 1:
    if sys.argv[1] == ''pro'':
        os.environ.setdefault("DJANGO_SETTINGS_MODULE", "settings.settings_pro")
    else:
        os.environ.setdefault("DJANGO_SETTINGS_MODULE", "settings.settings_test")
else:
    os.environ.setdefault("DJANGO_SETTINGS_MODULE", "settings.settings_test")

import django
from django.conf import settings

''''''
Django 版本大于等于1.7的时候，需要加上下面两句
import django
django.setup()
否则会抛出错误 django.core.exceptions.AppRegistryNotReady: Models aren''t loaded yet.
''''''
if django.VERSION >= (1, 7):  # 自动判断版本
    django.setup()

logger = logging.getLogger(''bss'')

pidfile = ''logs/bss.pid''


def clean():
    try:
        logger.info(''删除锁文件%s'', pidfile)
        if os.path.exists(pidfile):
            os.remove(pidfile)
        logger.info(''删除锁文件%s成功'', pidfile)
        return 1
    except Exception as e:
        msg = "删除锁文件%s失败" % e
        logger.error(msg, exc_info=True)
        return 0


def lock():
    try:
        logger.info(''创建锁文件%s'', pidfile)
        file(pidfile, ''w+'').write(''%s\n'' % os.getpid())
        logger.info(''创建锁文件%s成功'', pidfile)
    except Exception as e:
        msg = "创建锁文件%s失败" % e
        logger.error(msg, exc_info=True)
        sys.exit(0)


class BssService(object):
    def __init__(self):
        self.period_url = settings.BILLING_ALL_URL

    def build(self):
        logger.info("billing task begin>>>>>>>>>>>>>>>>>>")
        # do something
        logger.info("billing task   end>>>>>>>>>>>>>>>>>>")


if __name__ == "__main__":
    if not os.path.exists(pidfile):
        lock()
        bs = BssService()
        bs.build()
        status = clean()
        n = 10
        while status == 0 and n > 0:
            time.sleep(1)
            status = clean()
            n -= 1
    else:
        logger.info("其他进程正在执行!")