实战：10 种实现延迟任务的方法，附代码！

小鱼儿 2023-09-28 17:56 63阅读 0赞

这篇文章的诞生要感谢一位读者，是他让这篇**优秀的文章**有了和大家见面的机会，重点是**优秀文章**，哈哈。

事情的经过是这样的...

![4cc9ba3bb66bf63a1e49e01aa6b35787.png][]

不用谢我，送人玫瑰，手有余香。**相信接下来的内容一定不会让你失望，因为它将是目前市面上最好的关于“延迟任务”的文章**，这也一直是我写作追求的目标，让我的每一篇文章都比市面上的好那么一点点。

好了，话不多说，直接进入今天的主题，本文的主要内容如下图所示：

![5ce7e64d904c480efb573960f462d722.png][]

### 什么是延迟任务？ ###

顾明思议，我们**把需要延迟执行的任务叫做延迟任务**。

延迟任务的**使用场景**有以下这些：

1.  红包 24 小时未被查收，需要延迟执退还业务；
2.  每个月账单日，需要给用户发送当月的对账单；
3.  订单下单之后 30 分钟后，用户如果没有付钱，系统需要自动取消订单。

等事件都需要使用延迟任务。

### 延迟任务实现思路分析 ###

延迟任务**实现的关键是在某个时间节点执行某个任务**。基于这个信息我们可以想到**实现延迟任务的手段**有以下两个：

1.  自己手写一个“死循环”一直判断当前时间节点有没有要执行的任务；
2.  借助 JDK 或者第三方提供的工具类来实现延迟任务。

而通过 JDK 实现延迟任务我们能想到的关键词是：DelayQueue、ScheduledExecutorService，而第三方提供的延迟任务执行方法就有很多了，例如：Redis、Netty、MQ 等手段。

### 延迟任务实现 ###

下面我们将结合代码来讲解每种延迟任务的具体实现。

#### 1.无限循环实现延迟任务 ####

此方式我们需要开启一个无限循环一直扫描任务，然后使用一个 Map 集合用来存储任务和延迟执行的时间，实现代码如下：

import java.time.Instant;
    import java.time.LocalDateTime;
    import java.util.HashMap;
    import java.util.Iterator;
    import java.util.Map;
    
    /**
     * 延迟任务执行方法汇总
     */
    public class DelayTaskExample {
        // 存放定时任务
        private static Map<String, Long> _TaskMap = new HashMap<>();
    
        public static void main(String[] args) {
            System.out.println("程序启动时间：" + LocalDateTime.now());
            // 添加定时任务
            _TaskMap.put("task-1", Instant.now().plusSeconds(3).toEpochMilli()); // 延迟 3s
    
            // 调用无限循环实现延迟任务
            loopTask();
        }
    
        /**
         * 无限循环实现延迟任务
         */
        public static void loopTask() {
            Long itemLong = 0L;
            while (true) {
                Iterator it = _TaskMap.entrySet().iterator();
                while (it.hasNext()) {
                    Map.Entry entry = (Map.Entry) it.next();
                    itemLong = (Long) entry.getValue();
                    // 有任务需要执行
                    if (Instant.now().toEpochMilli() >= itemLong) {
                        // 延迟任务，业务逻辑执行
                        System.out.println("执行任务：" + entry.getKey() +
                                " ，执行时间：" + LocalDateTime.now());
                        // 删除任务
                        _TaskMap.remove(entry.getKey());
                    }
                }
            }
        }
    }

以上程序执行的结果为：

> 程序启动时间：2020-04-12T18:51:28.188
> 
> 执行任务：task-1 ，执行时间：2020-04-12T18:51:31.189

可以看出任务延迟了 3s 钟执行了，符合我们的预期。

#### 2.Java API 实现延迟任务 ####

Java API 提供了**两种实现延迟任务的方法：DelayQueue 和 ScheduledExecutorService。**

① ScheduledExecutorService 实现延迟任务

我们可以使用 ScheduledExecutorService 来以固定的频率一直执行任务，实现代码如下：

public class DelayTaskExample {
        public static void main(String[] args) {
            System.out.println("程序启动时间：" + LocalDateTime.now());
            scheduledExecutorServiceTask();
        }
    
        /**
         * ScheduledExecutorService 实现固定频率一直循环执行任务
         */
        public static void scheduledExecutorServiceTask() {
            ScheduledExecutorService executor = Executors.newScheduledThreadPool(1);
            executor.scheduleWithFixedDelay(
                    new Runnable() {
                        @Override
                        public void run() {
                            // 执行任务的业务代码
                            System.out.println("执行任务" +
                                    " ，执行时间：" + LocalDateTime.now());
                        }
                    },
                    2, // 初次执行间隔
                    2, // 2s 执行一次
                    TimeUnit.SECONDS);
        }
    }

[4cc9ba3bb66bf63a1e49e01aa6b35787.png]: https://img-blog.csdnimg.cn/img_convert/4cc9ba3bb66bf63a1e49e01aa6b35787.png
[5ce7e64d904c480efb573960f462d722.png]: https://img-blog.csdnimg.cn/img_convert/5ce7e64d904c480efb573960f462d722.png