工具-----滴答滴答(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

相关文章

springboot集成easypoi导出word换行处理过程

《springboot集成easypoi导出word换行处理过程》SpringBoot集成Easypoi导出Word时,换行符n失效显示为空格,解决方法包括生成段落或替换模板中n为回车,同时需确... 目录项目场景问题描述解决方案第一种:生成段落的方式第二种:替换模板的情况,换行符替换成回车总结项目场景s

SpringBoot集成redisson实现延时队列教程

《SpringBoot集成redisson实现延时队列教程》文章介绍了使用Redisson实现延迟队列的完整步骤,包括依赖导入、Redis配置、工具类封装、业务枚举定义、执行器实现、Bean创建、消费... 目录1、先给项目导入Redisson依赖2、配置redis3、创建 RedissonConfig 配

SpringBoot中@Value注入静态变量方式

《SpringBoot中@Value注入静态变量方式》SpringBoot中静态变量无法直接用@Value注入,需通过setter方法,@Value(${})从属性文件获取值,@Value(#{})用... 目录项目场景解决方案注解说明1、@Value("${}")使用示例2、@Value("#{}"php

SpringBoot分段处理List集合多线程批量插入数据方式

《SpringBoot分段处理List集合多线程批量插入数据方式》文章介绍如何处理大数据量List批量插入数据库的优化方案:通过拆分List并分配独立线程处理,结合Spring线程池与异步方法提升效率... 目录项目场景解决方案1.实体类2.Mapper3.spring容器注入线程池bejsan对象4.创建

线上Java OOM问题定位与解决方案超详细解析

《线上JavaOOM问题定位与解决方案超详细解析》OOM是JVM抛出的错误,表示内存分配失败,:本文主要介绍线上JavaOOM问题定位与解决方案的相关资料,文中通过代码介绍的非常详细,需要的朋... 目录一、OOM问题核心认知1.1 OOM定义与技术定位1.2 OOM常见类型及技术特征二、OOM问题定位工具

基于 Cursor 开发 Spring Boot 项目详细攻略

《基于Cursor开发SpringBoot项目详细攻略》Cursor是集成GPT4、Claude3.5等LLM的VSCode类AI编程工具,支持SpringBoot项目开发全流程,涵盖环境配... 目录cursor是什么?基于 Cursor 开发 Spring Boot 项目完整指南1. 环境准备2. 创建

Spring Security简介、使用与最佳实践

《SpringSecurity简介、使用与最佳实践》SpringSecurity是一个能够为基于Spring的企业应用系统提供声明式的安全访问控制解决方案的安全框架,本文给大家介绍SpringSec... 目录一、如何理解 Spring Security?—— 核心思想二、如何在 Java 项目中使用?——

SpringBoot+RustFS 实现文件切片极速上传的实例代码

《SpringBoot+RustFS实现文件切片极速上传的实例代码》本文介绍利用SpringBoot和RustFS构建高性能文件切片上传系统,实现大文件秒传、断点续传和分片上传等功能,具有一定的参考... 目录一、为什么选择 RustFS + SpringBoot?二、环境准备与部署2.1 安装 RustF

springboot中使用okhttp3的小结

《springboot中使用okhttp3的小结》OkHttp3是一个JavaHTTP客户端,可以处理各种请求类型,比如GET、POST、PUT等,并且支持高效的HTTP连接池、请求和响应缓存、以及异... 在 Spring Boot 项目中使用 OkHttp3 进行 HTTP 请求是一个高效且流行的方式。

java.sql.SQLTransientConnectionException连接超时异常原因及解决方案

《java.sql.SQLTransientConnectionException连接超时异常原因及解决方案》:本文主要介绍java.sql.SQLTransientConnectionExcep... 目录一、引言二、异常信息分析三、可能的原因3.1 连接池配置不合理3.2 数据库负载过高3.3 连接泄漏