60

cron“现代”守护进程如何在内部安排他们的工作？有些cronds 过去常常通过at. 因此，在写出 crontab 后，会crond：

  1. 解析所有未来事件的 crontab 和间隔的睡眠？
  2. 每分钟轮询一次聚合的 crontab 数据库以确定当前时间是否与计划模式匹配？
  3. 其他？

谢谢，

4

2 回答 2

75

在这个问题中听到了一些蟋蟀。带有一些离散事件模拟论文和维基百科的优秀'ol RTFC：

http://en.wikipedia.org/wiki/Cron#Multi-user_capability

这个 cron 使用的算法如下：

  1. 启动时，在所有帐户持有人的主目录中查找名为 .crontab 的文件。
  2. 对于找到的每个 crontab 文件，确定下一次运行每个命令的时间。
  3. 将这些命令及其相应时间和“五场”时间说明符放在 Franta-Maly 事件列表中。
  4. 进入主循环：
    1. 检查队列头部的任务条目，计算将来要运行多长时间。
    2. 睡那段时间。
    3. 在唤醒并验证正确时间后，使用创建它的用户的权限执行队列头部的任务（在后台）。
    4. 确定未来下次运行该命令的时间，并将其放回当时的事件列表中
于 2010-11-10T04:34:55.807 回答
13

我写了一篇博客文章来描述它。
从那里引用相关文本：

  • 我们可以有一个有限的线程池，它将通过从PriorityBlockingQueue优先级为的（线程安全堆）中提取所有任务来执行所有任务job.nextExecutionTime()。
  • 这意味着该堆的顶部元素将始终是最快触发的元素。
  • 我们将遵循标准的线程池生产者-消费者模式。
  • 我们将有一个线程在无限循环中运行，并在从队列中消耗它们后将新作业提交到线程池。让我们称之为QueueConsumerThread：
void goToSleep(job, jobQueue){
    jobQueue.push(job);
    sleep(job.nextExecutionTime() - getCurrentTime());
}

void executeJob(job, jobQueue){
    threadpool.submit(job); // async call
    if (job.isRecurring()) {
        job = job.copy().setNextExecutionTime(getCurrentTime() + job.getRecurringInterval());
        jobQueue.add(job);
    }
}

@Override
void run(){
    while(true)
    {
        job = jobQueue.pop()
        if(job.nextExecutionTime() > getCurrentTime()){
            // Nothing to do
            goToSleep(job, jobQueue)
        }
        else{
            executeJob(job, jobQueue)
        }
    }
}
  • 还有一个线程将监视 crontab 文件中是否有任何新作业添加并将它们推送到队列中。
  • 让我们称之为QueueProducerThread：
@Override
void run()
{
    while(true)
    {
        newJob = getNewJobFromCrontabFile() // blocking call
        jobQueue.push(newJob)
    }
}
  • 但是，这样做有一个问题：
    • 想象一下 Thread1 正在睡觉，一个小时后会醒来。
    • 与此同时，一个新任务到达，它应该每分钟运行一次。
    • 这个新任务要在一小时后才能开始执行。
  • 为了解决这个问题，我们可以让 ProducerThread 将 ConsumerThread 从睡眠中强行唤醒，只要新任务必须比队列中的前面任务运行得更快：
@Override
void run()
{
    while(true)
    {
        newJob = getNewJobFromCrontabFile() // blocking call
        jobQueue.push(newJob)
        if(newJob == jobQueue.peek())
        {
            // The new job is the one that will be scheduled next.
            // So wakeup consumer thread so that it does not oversleep.
            consumerThread.interrupt()
        }
    }
}

请注意，这可能不是 cron 在内部实现的方式。但是，这是我能想到的最优化的解决方案。它不需要轮询，所有线程都会休眠，直到它们需要做任何工作。

于 2020-05-09T08:27:04.750 回答