Java多线程基础-10:代码案例之定时器(一)

简介: `Timer` 是 Java 中的一个定时器类,用于在指定延迟后执行指定的任务。它常用于实现定时任务,例如在网络通信中设置超时或定期清理数据。`Timer` 的核心方法是 `schedule()`,它可以安排任务在延迟一段时间后执行。`

定时器就是一个闹钟。它可以设定一个时间,当时间到,就可以执行某个指定的代码。


定时器是实际开发中的一种非常常用的组件。比如网络通信中,如果对方 500ms 内没有返回数据,则要求断开连接尝试重连;又比如一个 Map,希望里面的某个 key 在 3s 之后过期(自动删除)。类似于这样的场景就需要用到定时器。


Java标准库(java.util)中提供了一个定时器类:Timer。Timer 类的核心方法为 schedule()。


一、Timer类的使用


下面是使用Timer类创建定时器的代码示例,通过创建Timer对象timer,与调用timer的schedule()方法完成定时器的设定。


1.import java.util.Timer;
import java.util.TimerTask;
 
public class Test {
    public static void main(String[] args) {
        //1-创建Timer对象
        Timer timer = new Timer();
        //2-设定定时效果:5秒
        timer.schedule(new TimerTask(){
            @Override
            public void run() {
                System.out.println("hello");
            }
        },5000);
        System.out.println("BBB");
    }
}


运行代码结果如下:立即执行System.out.println("BBB");语句打印出BBB,等待5s后,执行定时器schedule()中设定的语句,打印"hello"。



1、schedule()方法


schedule()方法的作用是在某个特定的时间后,安排执行某个指定的操作。它有多个重载:



这些重载的共同点是,第一个参数为被安排的任务task,第二个参数(或后面的所有参数共同)表示设定的任务将要执行的时间。


以schedule(TimerTask task, long delay)为例,它的两个参数分别是:


  • task:被安排的任务。
  • delay:在任务执行之前的等待时间(毫秒数)。


Timer timer = new Timer();
timer.schedule(new TimerTask() {
    @Override
    public void run() {
        System.out.println("hello");
   }
}, 3000);


这里的第一个参数TimerTask,本质上就是一个Runnable。查看TimerTask的源码可以发现,它其实是一个实现了Runnable接口的抽象类。因此,当创建TimerTask对象时,也需要重写实现run()方法。run()方法中定义的行为,表示任务具体要干什么。


(new TimerTask() { ... }:创建一个匿名内部类,继承自TimerTask,并重写了run()方法。)



程序启动后,立即打印出BBB,但未立即执行计时器timer中的代码。等待5秒后,程序打印hello。


这里有一个小细节:打印完毕hello后,程序并未终止退出。这是因为Timer里内置的前台线程阻止了当前进程结束。事实上,run方法的执行正是靠Timer内部的线程控制在时间到了之后执行的。(后面会讲解如何自己实现一个Timer类,Timer内部的线程是如何控制定时的,在那里会有只管的感受。)


2、定时器的应用场景


定时器的应用场景很多,尤其是在网络编程中。


实际中,很多的“等待”并不是无期限的,而是应当指定一个超时时间。比如打开浏览器,访问CSDN。如果此时的网络状况不是很好,那么加载的时间就可能会非常久。所以,浏览器会设置一个超时时间,如果达到了当前的超时时间还没有等待结果,就会提醒用户不要再等待下去了(504 gateway time out)。


3、用Timer管理多个任务


定时器内部可以管理很多个任务。如以下代码中,同时给定时器注册5个任务:


import java.util.Timer;
import java.util.TimerTask;
 
public class Test {
    public static void main(String[] args) {
        //1-创建定时器对象timer
        Timer timer = new Timer();
 
        //2-多次调用schedule()方法,给定时器注册多个任务
        timer.schedule(new TimerTask(){
            @Override
            public void run() {
                System.out.println("hello5");
            }
        },5000);
 
        timer.schedule(new TimerTask(){
            @Override
            public void run() {
                System.out.println("hello4");
            }
        },4000);
 
        timer.schedule(new TimerTask(){
            @Override
            public void run() {
                System.out.println("hello3");
            }
        },3000);
 
        timer.schedule(new TimerTask(){
            @Override
            public void run() {
                System.out.println("hello2");
            }
        },2000);
 
        timer.schedule(new TimerTask(){
            @Override
            public void run() {
                System.out.println("hello1");
            }
        },1000);
 
        System.out.println("hello0");
    }
}


运行程序后,立即打印hello0,之后每隔一秒进行一次打印。



这里就像传说中时间复杂度为O(0)的休眠排序法(笑)(手动滑稽)


二、代码实现Timer


代码实现Timer主要要考虑到两个问题:


a. 如何实现Timer对象可以同时管理多个任务?


虽然任务有很多,但它们的触发事件是不同的。因此,只需要有一个或一组工作线程来负责每次找这些任务中时间最先达到的即可。


换句话说,一个线程先执行最早的的任务,做完了之后再执行第二早的任务,以此类推。而所有任务中,时间到了的就执行,没到的就再等等。


如何实现“每次找到这些任务中时间最先到达的任务”?——堆!


堆heap是这里要用到的核心数据结构!(排序的效率要低于堆,且插入新的元素时,要维持原序列的规律比较困难。)


Java标准库中就提供了 PriorityQueue.


b. 定时器可能是有多个线程在执行 schedule 方法,那么就希望在多线程下操作 PriorityQueue 还能线程安全。


要保证线程安全,就要更进一步:Java标准库中提供了带优先级的阻塞队列,能够解决线程安全这个问题:PriorityBlockingQueue


通过查看优先级阻塞队列的源码可知,它遵循和优先级队列一样的顺序。可以根据任务的执行时间来建小根堆。不断取队头元素,取出的就是其中最小的元素。需要注意的是,该结构只有阻塞的入队列和阻塞的出队列,没有阻塞的查看队头元素方法。


1、实现思路


a.初步代码


首先创建一个MyTimer来模拟Timer,是一个自定义的定时器类。该类中封装有核心数据结构PriorityBlockingQueue。另外,创建一个类MyTask用于描述一个要执行的任务。一个要执行的任务中包含两方面信息,即:具体要做什么+什么时候做。


要特别注意的是,为了后续的判定方便,MyTask中的时间属性设定为绝对时间。


MyTimer定时器类中定义schedule()方法。其中根据传入的参数构造Task,将其插入队列中即可。注意,schedule()参数中的delay指的是相对时间,如3000,表示的是任务要在3000毫秒后执行。


因此,在构造MyTask时,要有一步绝对时间与相对时间之间的转换:


this.time = System.currentTimeMillis() + delay;


System.currentTimeMillis() 用于获取当前毫秒级别的时间戳,即当前时刻和基准时刻的ms数之差(基准时刻是1970年1月1日00:00:00.000)


代码展现如下:


class MyTask{
    public Runnable runnable;
    public long time;   //为了方便后续判定,使用的是绝对的时间戳
 
    public MyTask(Runnable runnable, long delay) {
        this.runnable = runnable;
        this.time = System.currentTimeMillis() + delay; //转换:相对时间delay + 当前时间戳 => 绝对的时间戳
    }
}
 
//自定义定时器类
class MyTimer {
    //核心数据结构,带有优先级的阻塞队列
    private PriorityBlockingQueue<MyTask> queue = new PriorityBlockingQueue<>();
 
    //此处的delay是一个相对时间,表示间隔多少时间后执行该任务
    public void schedule(Runnable runnable, long delay) {
        //根据参数构造MyTask,插入队列即可
        MyTask myTask = new MyTask(runnable,delay);
        queue.put(myTask);
    }
}


b.构造线程来具体执行任务


在计时器类的构造方法中构造扫描线程,用来扫描优先级阻塞队列中的各个任务是否到达可执行的时间。


逻辑很简单:先从queue中取出一个任务,这个任务应是所有任务中时间最小的。再获取当前时间curTime。通过比较curTime与myTask.time的大小来判断是否达到了该任务的执行时间。如果到达了,则执行myTask.runnable.run();如果没有达到,那么只能把刚才取出的任务放回队列中。


//注:该代码不是最终版,仅表明思路
 
class MyTimer {
    ...    //其他代码
 
 
    // 在这里构造线程,负责不停地扫描队首元素,判断该任务是否可以执行
    public MyTimer() {
        Thread t = new Thread(()->{
            while (true) {
                try {
                    MyTask myTask = queue.take();
                    long curTime = System.currentTimeMillis();  //获取当前时间
                    if(curTime < myTask.time) {
                        //当前时间小于任务时间:时间还没到
                        //暂不执行,要把刚才取出的任务塞回队列中
                        queue.put(myTask);
                    }else{
                        //时间到了,执行任务
                        myTask.runnable.run();  //执行任务
                    }
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
        });
        t.start();
    }
}


但是上面的代码存在两个严重的问题:


1、当前队列里的MyTask元素是按照什么规则来表示优先级的?

2、while(true)带来了CPU的忙等问题。


Java多线程基础-10:代码案例之定时器(二)+

https://developer.aliyun.com/article/1520554?spm=a2c6h.13148508.setting.17.75194f0e0dvo2R

相关文章
|
1天前
|
Java API 开发者
探索Java中的Lambda表达式:简洁与强大的代码实践
本文深入探讨Java中Lambda表达式的定义、用法及优势,通过实例展示其如何简化代码、提升可读性,并强调在使用中需注意的兼容性和效率问题。Lambda作为Java 8的亮点功能,不仅优化了集合操作,还促进了函数式编程范式的应用,为开发者提供了更灵活的编码方式。
|
1天前
|
Java Linux Python
Linux环境下 代码java调用python出错
Linux环境下 代码java调用python出错
12 3
|
1天前
|
存储 Java 索引
使用java代码实现左右括号查找
使用java代码实现左右括号查找
|
5天前
|
Java 开发者
Java中的多线程基础与应用
【9月更文挑战第22天】在Java的世界中,多线程是一块基石,它支撑着现代并发编程的大厦。本文将深入浅出地介绍Java中多线程的基本概念、创建方法以及常见的应用场景,帮助读者理解并掌握这一核心技术。
|
1天前
|
Java 调度
Java-Thread多线程的使用
这篇文章介绍了Java中Thread类多线程的创建、使用、生命周期、状态以及线程同步和死锁的概念和处理方法。
Java-Thread多线程的使用
|
2天前
|
算法 Java
java 概率抽奖代码实现
java 概率抽奖代码实现
|
4天前
|
Java 调度 开发者
Java中的多线程编程:从基础到实践
本文旨在深入探讨Java多线程编程的核心概念和实际应用,通过浅显易懂的语言解释多线程的基本原理,并结合实例展示如何在Java中创建、控制和管理线程。我们将从简单的线程创建开始,逐步深入到线程同步、通信以及死锁问题的解决方案,最终通过具体的代码示例来加深理解。无论您是Java初学者还是希望提升多线程编程技能的开发者,本文都将为您提供有价值的见解和实用的技巧。
14 2
|
1天前
|
Java 数据处理 调度
Java中的多线程编程:从基础到实践
本文深入探讨了Java中多线程编程的基本概念、实现方式及其在实际项目中的应用。首先,我们将了解什么是线程以及为何需要多线程编程。接着,文章将详细介绍如何在Java中创建和管理线程,包括继承Thread类、实现Runnable接口以及使用Executor框架等方法。此外,我们还将讨论线程同步和通信的问题,如互斥锁、信号量、条件变量等。最后,通过具体的示例展示了如何在实际项目中有效地利用多线程提高程序的性能和响应能力。
|
2天前
|
安全 算法 Java
Java中的多线程编程:从基础到高级应用
本文深入探讨了Java中的多线程编程,从最基础的概念入手,逐步引导读者了解并掌握多线程开发的核心技术。无论是初学者还是有一定经验的开发者,都能从中获益。通过实例和代码示例,本文详细讲解了线程的创建与管理、同步与锁机制、线程间通信以及高级并发工具等主题。此外,还讨论了多线程编程中常见的问题及其解决方案,帮助读者编写出高效、安全的多线程应用程序。
|
3天前
|
安全 Java 调度
python3多线程实战(python3经典编程案例)
该文章提供了Python3中多线程的应用实例,展示了如何利用Python的threading模块来创建和管理线程,以实现并发执行任务。
8 0