工具-----滴答滴答(Java计时器)

2023-11-09 03:50
文章标签 java 工具 计时器 滴答

本文主要是介绍工具-----滴答滴答(Java计时器),希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

Java计时器

一、作用:

计时器也就是用来计时的东西。当你需要隔一段时间去干一件事的时候就可以用到它,比如:

  1. 当某拼夕夕网站的抢购在一段规定的时间内需要结束时。
  2. 比如某宝的页面需要在一段规定的时间里刷新页面时。
  3. 当你设置的闹钟在规定时间将你叫醒。

而此时我们要做的事可以写成一个接口,由用户规定干什么事情。

二、实现原理:

  1. wait(); 调用此方法将使该线程进入阻塞态,直到被notify才会重新进入就绪态。
  2. wait(int gap); 调用此方法将使该线程进入阻塞态,直到被notify才会重新进入就绪态。设置了超时时间的wait方法一旦过了时间,并不需要其他线程执行notify也能自动解除阻塞。
  3. lock.notify();调用此方法将lock锁上的线程唤醒;

对于sleep:sleep()方法在睡眠的时候一直占用锁资源,也就是说,sleep睡眠时间没有到,其它线程就得不到锁,无法进入就绪态,得不到CPU的使用权。因此使用sleep()方法会浪费CPU的资源,所以后面使用wait()方法。

三、方案阐述即代码展示:

  • 方案:
  1. 首先定义一个接口,此接口中的方法时使用者自己写的要定时执行的任务。
  2. 其次新建一个类有两个线程,一个线程用来计时,一个线程用来执行任务。

(对于为什么给两个线程?答:因为若只有一个线程即计时也执行任务,但要考虑到任务的执行也是需要占用时间的,会造成计时误差。所以开辟出两个线程去执行)

  • 代码显示:
package com.smy.timer.didadida;public interface IDidadida {private static final int DEFAULT_dELAY_tIME = 1000;void doSomething();
}
package com.smy.timer.didadida;import java.util.concurrent.ScheduledThreadPoolExecutor;public class Didadida implements Runnable { //延迟时间   private int delayTime;//对象锁private Object lock;//开始计时和结束计时的标志private volatile boolean goon;//接口(接口中的方法即任务)private IDidadida didadida;public Didadida() {this(DEFAULT_dELAY_tIME, null);}//初始化public Didadida(int delayTime, IDidadida didadida) {lock = new Object();this.delayTime = delayTime;this.didadida = didadida;}//可以由用户来设置public void setDidadida(IDidadida didadida) {this.didadida = didadida;}//开始计时public void startTimer() {this.goon = true;//开启两个线程new Thread(new TimeWorker(), "timeWorker").start();new Thread(this, "didadida").start();}//结束计时public void endTimer() {if (goon == false) {System.out.println("now had ended");return;}if (didadida == null) {System.out.println("无事可做!");return;}this.goon = false;}//用来计时的线程@Overridepublic void run() {while (goon) {synchronized (lock) {try {lock.wait(delayTime);//这里是唤醒一个线程,用来专门执行任务lock.notify();} catch (InterruptedException e) {e.printStackTrace();}}}}//内部类(用来执行任务)class TimeWorker implements Runnable {@Overridepublic void run() {while (goon) {synchronized (lock) {try {lock.wait();} catch (InterruptedException e) {e.printStackTrace();}}didadida.doSomething();}}}
}

当然我们要看的核心当然是两个线程的执行:就是关于锁

首先,两个线程我们当然要让计时线程先跑起来,但由于时间片和优先级等的不确定性,我们必须用锁来加以限制。

  1. 给执行线程和计时线程都加锁,但在执行线程的一开始wait();这样就算执行线程得到CPU也可以先阻塞它。
  2. 而计时线程必将进入自己的锁块,并wait(delayTime);后再去唤醒执行线程执行dosomething方法。

注:此代码有两个需要注意的地方

  1. 若执行任务线程中执行dosomething的时间过长,还没有进入阻塞态,而计时线程已经去notify了,这时会无线程可唤醒。只能等下次线程去唤醒,所以当wait时间和dosomething的执行时间差距过大,将会产生成倍时间的误差,比如wait一秒,但是执行dosomething需要两秒,这时在第1秒去notify时还没执行完在第2秒notify时才会再去执行,这时我们设置的时间虽然是一秒,但其实是两秒(0秒时执行,2秒时执行......)。所以此时我们的工具是有误差的。
  2. dosomething方法必须写在锁块的外面,若在锁块里面,就必须等待执行完dosomething才能释放锁,这样就会产生计时误差。

 四、Test测试:

package com.smy.timer.didadida.test;import java.text.SimpleDateFormat;import com.smy.timer.didadida.Didadida;
import com.smy.timer.didadida.IDidadida;public class Test {public static void main(String[] args) {Didadida didadida = new Didadida(1000, new IDidadida() {SimpleDateFormat sdf = new SimpleDateFormat("yyyy年MM月dd日 HH:mm:ss");@Overridepublic void doSomething() {String data = sdf.format(System.currentTimeMillis());System.out.println("-------" + data);}});System.out.println("开始");didadida.startTimer();//		didadida.endTimer();}}

结果:给的参数是一秒

下面给出其缺陷的Test:

package com.smy.timer.didadida.test;import java.io.File;
import java.io.FileNotFoundException;
import java.io.FileOutputStream;
import java.io.IOException;
import java.text.SimpleDateFormat;import com.smy.timer.didadida.Didadida;
import com.smy.timer.didadida.IDidadida;public class Test {public static void main(String[] args) {Didadida didadida = new Didadida(1000, new IDidadida() {File file = new File("E:\\test.txt");SimpleDateFormat sdf = new SimpleDateFormat("yyyy年MM月dd日 HH:mm:ss");@Overridepublic void doSomething() {FileOutputStream fileOutputStream = null;try {fileOutputStream = new FileOutputStream(file);} catch (FileNotFoundException e1) {e1.printStackTrace();}for (int i = 0; i < 1000000; i++) {try {fileOutputStream.write(i);} catch (IOException e) {e.printStackTrace();}}String data = sdf.format(System.currentTimeMillis());System.out.println("-------" + data);try {fileOutputStream.close();} catch (IOException e) {e.printStackTrace();}}});System.out.println("开始");didadida.startTimer();//		didadida.endTimer();}}

 

可以看出是五秒一次即1的整数倍。 

这篇关于工具-----滴答滴答(Java计时器)的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/373866

相关文章

Spring Boot中WebSocket常用使用方法详解

《SpringBoot中WebSocket常用使用方法详解》本文从WebSocket的基础概念出发,详细介绍了SpringBoot集成WebSocket的步骤,并重点讲解了常用的使用方法,包括简单消... 目录一、WebSocket基础概念1.1 什么是WebSocket1.2 WebSocket与HTTP

SpringBoot+Docker+Graylog 如何让错误自动报警

《SpringBoot+Docker+Graylog如何让错误自动报警》SpringBoot默认使用SLF4J与Logback,支持多日志级别和配置方式,可输出到控制台、文件及远程服务器,集成ELK... 目录01 Spring Boot 默认日志框架解析02 Spring Boot 日志级别详解03 Sp

java中反射Reflection的4个作用详解

《java中反射Reflection的4个作用详解》反射Reflection是Java等编程语言中的一个重要特性,它允许程序在运行时进行自我检查和对内部成员(如字段、方法、类等)的操作,本文将详细介绍... 目录作用1、在运行时判断任意一个对象所属的类作用2、在运行时构造任意一个类的对象作用3、在运行时判断

Python使用OpenCV实现获取视频时长的小工具

《Python使用OpenCV实现获取视频时长的小工具》在处理视频数据时,获取视频的时长是一项常见且基础的需求,本文将详细介绍如何使用Python和OpenCV获取视频时长,并对每一行代码进行深入解析... 目录一、代码实现二、代码解析1. 导入 OpenCV 库2. 定义获取视频时长的函数3. 打开视频文

java如何解压zip压缩包

《java如何解压zip压缩包》:本文主要介绍java如何解压zip压缩包问题,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录Java解压zip压缩包实例代码结果如下总结java解压zip压缩包坐在旁边的小伙伴问我怎么用 java 将服务器上的压缩文件解压出来,

SpringBoot中SM2公钥加密、私钥解密的实现示例详解

《SpringBoot中SM2公钥加密、私钥解密的实现示例详解》本文介绍了如何在SpringBoot项目中实现SM2公钥加密和私钥解密的功能,通过使用Hutool库和BouncyCastle依赖,简化... 目录一、前言1、加密信息(示例)2、加密结果(示例)二、实现代码1、yml文件配置2、创建SM2工具

Spring WebFlux 与 WebClient 使用指南及最佳实践

《SpringWebFlux与WebClient使用指南及最佳实践》WebClient是SpringWebFlux模块提供的非阻塞、响应式HTTP客户端,基于ProjectReactor实现,... 目录Spring WebFlux 与 WebClient 使用指南1. WebClient 概述2. 核心依

Spring Boot @RestControllerAdvice全局异常处理最佳实践

《SpringBoot@RestControllerAdvice全局异常处理最佳实践》本文详解SpringBoot中通过@RestControllerAdvice实现全局异常处理,强调代码复用、统... 目录前言一、为什么要使用全局异常处理?二、核心注解解析1. @RestControllerAdvice2

Spring IoC 容器的使用详解(最新整理)

《SpringIoC容器的使用详解(最新整理)》文章介绍了Spring框架中的应用分层思想与IoC容器原理,通过分层解耦业务逻辑、数据访问等模块,IoC容器利用@Component注解管理Bean... 目录1. 应用分层2. IoC 的介绍3. IoC 容器的使用3.1. bean 的存储3.2. 方法注

Spring事务传播机制最佳实践

《Spring事务传播机制最佳实践》Spring的事务传播机制为我们提供了优雅的解决方案,本文将带您深入理解这一机制,掌握不同场景下的最佳实践,感兴趣的朋友一起看看吧... 目录1. 什么是事务传播行为2. Spring支持的七种事务传播行为2.1 REQUIRED(默认)2.2 SUPPORTS2