曾续缘

切换主题

实现定时任务的技术 ​

无限循环 ​

无限循环是最简单的定时任务实现方式。它通过在一个线程中不断循环，并在每次循环中检查当前时间是否到达任务的执行时间来实现定时功能。

实现步骤：

  1. 创建一个线程。
  2. 在线程中执行一个无限循环。
  3. 在循环中使用 sleep 方法等待下一个任务的执行时间。
  4. 当到达执行时间时，执行任务。
  5. 重复步骤3和4。

优点：

  • 实现简单，易于理解。
  • 适用于任务数量不多，且对精度要求不高的场景。

缺点：

  • 精度较低，依赖于 sleep 的准确性。
  • 不适合大量任务，因为需要手动管理所有任务的执行时间。

示例：

查看代码
java
public class BackupTask {
    public static void main(String[] args) {
        long backupInterval = 60_000; // 每分钟备份一次
        long nextBackupTime = System.currentTimeMillis() + backupInterval;

        while (true) {
            long currentTime = System.currentTimeMillis();
            if (currentTime >= nextBackupTime) {
                backup(); // 执行备份任务
                nextBackupTime = currentTime + backupInterval;
            }
            try {
                Thread.sleep(Math.max(0, nextBackupTime - currentTime));
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }

    private static void backup() {
        System.out.println("Backing up data...");
        // 备份数据的逻辑
    }
}

最小堆 ​

最小堆是一种基于优先队列的数据结构，可以用来实现定时任务。Java中的 Timer 底层就是使用最小堆来管理任务的。

实现步骤：

  1. 创建一个最小堆，用于存储所有任务。
  2. 任务按照执行时间排序，堆顶元素是下一个即将执行的任务。
  3. 在一个循环中，不断检查堆顶任务的执行时间。
  4. 如果当前时间大于或等于堆顶任务的执行时间，则执行该任务。
  5. 如果是周期性任务，更新任务的执行时间，并重新插入堆中。
  6. 重复步骤3到5。

优点：

  • 可以高效地管理大量任务。
  • 可以快速地添加、删除和调整任务。
  • 时间复杂度相对较低，对于插入和删除操作通常是 O(log n)。

缺点：

  • 需要额外的空间来存储任务队列。
  • 对于时间精度要求极高的场景，可能不够精确。

例子： Java中的 Timer 和 TimerTask 就是使用最小堆来实现定时任务的。

时间轮 ​

时间轮是一种专门用于定时任务调度的高效数据结构，特别适合于在固定的时间间隔内调度大量任务。

实现步骤：

  1. 创建一个固定大小的数组，作为时间轮的槽位。
  2. 每个槽位包含一个任务列表。
  3. 根据任务的执行时间，将任务添加到对应槽位的任务列表中。
  4. 在一个循环中，随着时间的推进，遍历时间轮的每个槽位。
  5. 执行每个槽位中的所有任务。
  6. 如果任务需要重复执行，则重新计算任务的执行时间，并添加到相应的槽位中。
  7. 重复步骤4到6。

优点：

  • 适用于大量任务的场景。
  • 时间复杂度低，通常为 O(1)。
  • 可以处理高并发的定时任务。

缺点：

  • 需要根据时间范围预先分配资源。
  • 对于精度要求极高的场景，可能不够精确。

例子： Netty中的 HashedWheelTimer 是使用时间轮来实现定时任务的。

分层时间轮 ​

分层时间轮（Hierarchical Timing Wheel）是由一系列按时间精度递增的时间轮组成，每个时间轮负责一定时间范围内的任务调度的数据结构。

原理 ​

分层时间轮的核心思想是将时间分割成不同的层次，每个层次负责不同粒度的计时。这样可以将时间精度与资源消耗达到一个平衡，对于近期的任务使用较高精度的时间轮，对于远期的任务则使用较低精度的时间轮。

  1. 基本结构：
    • 时间轮：通常是一个循环数组，数组的每个槽位代表一个时间间隔，例如一个槽位代表1毫秒。
    • 槽位：每个槽位可以是一个列表，用于存放该时间间隔内的所有任务。
    • 指针：指向当前时间的槽位，随着时间的推进而移动。
  2. 分层机制：
    • 粗粒度轮：用于处理较长时间间隔的任务，例如秒级。
    • 细粒度轮：用于处理较短时间间隔的任务，例如毫秒级。
    • 层级关系：当粗粒度轮的任务到期时，该任务会被下降到下一层细粒度轮中，由细粒度轮处理。
  3. 任务调度：
    • 添加任务：根据任务的到期时间，将其放入相应层级的时间轮的对应槽位中。
    • 时间推进：随着时间推进，最细粒度的时间轮指针会移动，当指针移动到某个槽位时，执行该槽位中的所有任务。
    • 层级切换：当一个层级的时间轮任务执行完毕，会检查更高层级的时间轮是否有任务到期，如果有，则将其下移到当前层级。

任务队列设置 ​

在分层时间轮中，任务队列的设置通常遵循以下步骤：

  1. 任务分类：根据任务的到期时间，将其分类到不同的时间轮层级中。
  2. 槽位分配：在相应的时间轮中找到任务对应的槽位。
  3. 任务插入：将任务添加到槽位对应的任务队列中。
  4. 时间同步：确保时间轮的时间与实际时间同步，以便于任务能够按时执行。

例如，对于一个分布式系统中的定时任务，可以按照以下方式设置任务队列：

  • 秒级任务：对于需要在秒级精度执行的任务，将其放入秒级时间轮的对应槽位中。
  • 毫秒级任务：对于需要更高精度（如毫秒级）的任务，首先放入秒级时间轮中，当秒级时间轮推进到该任务所在的槽位时，再将该任务精确地放入毫秒级时间轮的对应槽位中。

cron表达式 ​

Cron表达式是一种用于配置定时任务的时间格式，它允许用户以一种简洁的方式来定义复杂的调度模式。虽然Cron表达式的概念是通用的，并且在许多系统和框架中都有实现，但不同系统或框架可能会有略微不同的语法或者扩展特性。因此，在使用Cron表达式时，需要查阅所使用的具体系统或框架的文档，以确保表达式符合该环境的具体规则和限制。

Cron表达式的格式 ​

每个字段代表一个时间单位，从左到右依次是：

秒分时日月星期年可选
*****？空

上面的Cron表达式* * * * * ?表示当年每秒执行。

1. 秒（Seconds） ​

  • 取值范围： 0-59
  • 特殊字符：
    • *：代表该字段的所有可能值，例如*在秒字段中表示每秒。
    • ,：列举多个值，例如5,20表示在第5秒和第20秒。
    • -：指定一个范围，例如5-10表示从第5秒到第10秒。
    • /：指定增量，例如0/15表示从第0秒开始，每隔15秒。

2. 分钟（Minutes） ​

  • 取值范围： 0-59
  • 特殊字符： 同秒字段

3. 小时（Hours） ​

  • 取值范围： 0-23
  • 特殊字符： 同秒字段

4. 日期（Day of month） ​

  • 取值范围： 1-31
  • 特殊字符：
    • *：代表该字段的所有可能值。
    • ,：列举多个值。
    • -：指定一个范围。
    • /：指定增量。
    • L：表示月的最后一天。
    • W：表示工作日（星期一至星期五），如果日期是周末，则自动调整到最近的工作日。

5. 月份（Month） ​

  • 取值范围： 1-12 或 JAN-DEC（不区分大小写）
  • 特殊字符：
    • *：代表该字段的所有可能值。
    • ,：列举多个值。
    • -：指定一个范围。
    • /：指定增量。

6. 星期（Day of week） ​

  • 取值范围： 0-7（0和7都代表星期天）或 SUN-SAT（不区分大小写）
  • 特殊字符：
    • *：代表该字段的所有可能值。
    • ,：列举多个值。
    • -：指定一个范围。
    • /：指定增量。
    • L：表示月的最后一个星期几。
    • #：表示月的第几个星期几，例如3#2表示月的第二个星期三。

7. 年份（Year） ​

  • 取值范围： 空值或1970-2099
  • 特殊字符：
    • *：代表该字段的所有可能值。
    • ,：列举多个值。
    • -：指定一个范围。
    • /：指定增量。

语法规则 ​

  • 每个字段都有其特定的取值范围和特殊字符。
  • 字段之间用空格分隔。
  • ?字符可以用在日期和星期字段中，表示“不指定”。
  • 当指定日期（Day of month）时，星期（Day of week）字段必须使用?；反之亦然。
  • 年份字段是可选的，如果省略，则默认为当前年份。

Linux系统的格式 ​

Linux系统Cron表达式的格式通常由以下五个或六个字段组成：

* * * * * [command to execute]

每个字段代表不同的时间单位，具体如下：

  1. 分钟（Minutes）：0-59
  2. 小时（Hours）：0-23
  3. 日期（Day of Month）：1-31
  4. 月份（Month）：1-12
  5. 星期（Day of Week）：0-7（0和7都代表星期天）
  6. 命令（Command）：要执行的命令或脚本

字段说明 ​

  1. 分钟（Minutes）：表示每个小时的哪一分钟执行任务，范围是0-59。
  2. 小时（Hours）：表示每天的哪个小时执行任务，范围是0-23。
  3. 日期（Day of Month）：表示每月的哪一天执行任务，范围是1-31。
  4. 月份（Month）：表示每年的哪个月执行任务，范围是1-12。
  5. 星期（Day of Week）：表示每周的哪一天执行任务，范围是0-7，其中0和7都代表星期天。
  6. 命令（Command）：指定要执行的命令或脚本。

特殊字符 ​

Cron表达式支持以下特殊字符：

  • *：表示匹配该字段的所有可能值。例如，*在分钟字段中表示每分钟。
  • ,：用于指定列表中的多个值。例如，1,3,5在小时字段中表示在第1、3、5小时执行。
  • -：用于指定一个范围。例如，1-5在日期字段中表示从第1天到第5天。
  • /：用于指定增量。例如，*/2在小时字段中表示每两小时。
  • L：表示该月或该周的最后一天。例如，L在日期字段中表示每月的最后一天。
  • W：表示工作日（星期一到星期五），用于指定日期字段。例如，15W表示离15号最近的工作日。

示例 ​

当然，以下是一些具体的Cron表达式示例以及它们对应的含义：

每分钟执行一次任务 ​

* * * * * /path/to/script.sh

解释：

  • * 分钟：每分钟
  • * 小时：每个小时
  • * 日期：每天
  • * 月份：每个月
  • * 星期：每个星期
  • /path/to/script.sh 是要执行的脚本。

每天早上8点执行一次任务 ​

0 8 * * * /usr/local/bin/daily_backup.sh

解释：

  • 0 分钟：小时的第0分钟（即整点）
  • 8 小时：早上8点
  • * 日期：每天
  • * 月份：每个月
  • * 星期：每个星期
  • /usr/local/bin/daily_backup.sh 是要执行的脚本。

每周六的凌晨3点执行一次任务 ​

0 3 * * 6 /home/user/cleanup.sh

解释：

  • 0 分钟：小时的第0分钟（即整点）
  • 3 小时：凌晨3点
  • * 日期：每天
  • * 月份：每个月
  • 6 星期：星期六（注意，在某些系统中星期天可以用7表示）
  • /home/user/cleanup.sh 是要执行的脚本。

每个月的第一天中午12点执行一次任务 ​

0 12 1 * * /scripts/monthly_report.sh

解释：

  • 0 分钟：小时的第0分钟（即整点）
  • 12 小时：中午12点
  • 1 日期：每个月的第一天
  • * 月份：每个月
  • * 星期：每个星期
  • /scripts/monthly_report.sh 是要执行的脚本。

每个工作日的下午5点执行一次任务 ​

0 17 * * 1-5 /home/user/end_of_day.sh

解释：

  • 0 分钟：小时的第0分钟（即整点）
  • 17 小时：下午5点
  • * 日期：每天
  • * 月份：每个月
  • 1-5 星期：星期一到星期五（工作日）
  • /home/user/end_of_day.sh 是要执行的脚本。