欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

JavaEE線程安全定時器模式任務(wù)

 更新時間:2022年06月20日 11:08:54   作者:sugar?high  
這篇文章主要介紹了JavaEE線程安全定時器模式任務(wù),定時器模式像是一個鬧鐘定時,在一定時間之后被喚醒并執(zhí)行某個之前設(shè)定好的任務(wù),感興趣的小伙伴可以參考一下

前言

像是一個鬧鐘定時,在一定時間之后被喚醒并執(zhí)行某個之前設(shè)定好的任務(wù),join(指定超時時間),sleep(指定休眠時間)都是基于系統(tǒng)內(nèi)部的定時器來實現(xiàn)的。
java.util.Timer核心方法就一個,schedule參數(shù)有兩個:任務(wù)是啥(一段代碼),多長時間之后執(zhí)行

public class 定時器 {
? ? public static void main(String[] args) {
? ? ? ? Timer timer = new Timer();
? ? ? ? timer.schedule(new TimerTask() {
? ? ? ? ? ? @Override
? ? ? ? ? ? public void run() {
? ? ? ? ? ? ? ? System.out.println("hello timer");
? ? ? ? ? ? }
? ? ? ? }, 3000);
? ? }
}

Timer內(nèi)部組成

1.描述任務(wù)

創(chuàng)建一個專門的類來表示一個定時器的任務(wù)TimerTask,這個MyTask類的比較規(guī)則不是默認(rèn)存在的,需要我們手動指定按照時間大小來比較的。

//創(chuàng)建一個類表示一個任務(wù)
class MyTask{
? ? //任務(wù)描述
? ? private Runnable runnable;
? ? //任務(wù)具體啥時候干
? ? private long time;

? ? //after是一個時間間隔,不是覺得時間戳的值
? ? public MyTask(Runnable runnable, long after){
? ? ? ? this.runnable = runnable;
? ? ? ? this.time = System.currentTimeMillis() + after;
? ? }
? ? public void run(){
? ? ? ? runnable.run();
? ? }
}

2.組織任務(wù)

通過一定的數(shù)據(jù)結(jié)構(gòu)把一些任務(wù)給放到一起,標(biāo)準(zhǔn)庫有一個專門的數(shù)據(jù)結(jié)構(gòu)PriorityQueue,這里用到的數(shù)據(jù)結(jié)構(gòu)是PriorityBlockingQueue,及帶有優(yōu)先級又帶有阻塞隊列。此處的隊列要考慮到線程安全問題,可能在多個線程里進(jìn)行注冊任務(wù),同時還有一個專門的線程來取任務(wù)執(zhí)行,此時的隊列就需要注意線程安全問題。
其次為了避免盲等的現(xiàn)象,可以使用wait這樣的機(jī)制指定等待時間時間到了自然喚醒,計算出當(dāng)前時間和任務(wù)目標(biāo)的時間差即可。既然是指定一個等待時間為啥不用sleep而是用wait,sleep不能被中途喚醒,wait能夠被中途喚醒。在等待過程中可能有新的任務(wù)插入,新的任務(wù)是可能出現(xiàn)在之前所有任務(wù)的最前面,在schedule操作中就需要加上一個notify操作。

3.執(zhí)行時間到了的任務(wù)

需要執(zhí)行時間最靠前的任務(wù),就需要一個線程不停地去檢查當(dāng)前優(yōu)先隊列的對手元素,看看當(dāng)前最靠前的任務(wù)是不是時間到了

class MyTask implements Comparable<MyTask>{
? ? //任務(wù)描述
? ? private Runnable runnable;
? ? //任務(wù)具體啥時候干
? ? private long time;
? ? //delay是一個時間間隔,不是絕對時間戳的值
? ? public MyTask(Runnable runnable, long delay){
? ? ? ? this.runnable = runnable;
? ? ? ? this.time = System.currentTimeMillis() + delay;
? ? }
? ? public void run(){
? ? ? ? runnable.run();
? ? }
? ? public long getTime(){
? ? ? ? return time;
? ? }
? ? @Override
? ? public int compareTo(MyTask o) {
? ? ? ? //小的在前
? ? ? ? return (int)(this.time - o.time);
? ? }
}
class MyTimer{
? ? private Object locker = new Object();
? ? //定時器內(nèi)不要能夠存放多個任務(wù)
? ? private PriorityBlockingQueue<MyTask> queue = new PriorityBlockingQueue<>();
? ? public void schedule(Runnable runnable, long delay){
? ? ? ? MyTask task = new MyTask(runnable, delay);
? ? ? ? queue.put(task);
? ? ? ? //每次任務(wù)插入成功之后都喚醒一下掃描線程,讓線程重新檢查隊首的任務(wù)是否時間到要執(zhí)行
? ? ? ? synchronized (locker){
? ? ? ? ? ? locker.notify();
? ? ? ? }
? ? }
? ? public MyTimer(){
? ? ? ? Thread t = new Thread(() ->{
? ? ? ? ? ? while(true){
? ? ? ? ? ? ? ? try{
? ? ? ? ? ? ? ? ? ? //先取出隊首元素
? ? ? ? ? ? ? ? ? ? MyTask task = queue.take();
? ? ? ? ? ? ? ? ? ? //在比較一下看看當(dāng)前這個任務(wù)時間到了沒
? ? ? ? ? ? ? ? ? ? long curTime = System.currentTimeMillis();
? ? ? ? ? ? ? ? ? ? if(curTime < task.getTime()){
? ? ? ? ? ? ? ? ? ? ? ? //時間沒到把任務(wù)賽回到隊列中
? ? ? ? ? ? ? ? ? ? ? ? queue.put(task);
? ? ? ? ? ? ? ? ? ? ? ? //制定一個等待時間
? ? ? ? ? ? ? ? ? ? ? ? synchronized (locker){
? ? ? ? ? ? ? ? ? ? ? ? ? ? locker.wait(task.getTime() - curTime);
? ? ? ? ? ? ? ? ? ? ? ? }
? ? ? ? ? ? ? ? ? ? }else{
? ? ? ? ? ? ? ? ? ? ? ? //時間到了執(zhí)行任務(wù)
? ? ? ? ? ? ? ? ? ? ? ? task.run();
? ? ? ? ? ? ? ? ? ? }

? ? ? ? ? ? ? ? } catch (InterruptedException e) {
? ? ? ? ? ? ? ? ? ? e.printStackTrace();
? ? ? ? ? ? ? ? }
? ? ? ? ? ? }
? ? ? ? });
? ? ? ? t.start();
? ? }
}

public class 定時器 {
? ? public static void main(String[] args) {
? ? ? ? MyTimer myTimer = new MyTimer();
? ? ? ? myTimer.schedule(new Runnable() {
? ? ? ? ? ? @Override
? ? ? ? ? ? public void run() {
? ? ? ? ? ? ? ? System.out.println("hello timer");
? ? ? ? ? ? }
? ? ? ? }, 3000);
? ? ? ? myTimer.schedule(new Runnable() {
? ? ? ? ? ? @Override
? ? ? ? ? ? public void run() {
? ? ? ? ? ? ? ? System.out.println("hello ");
? ? ? ? ? ? }
? ? ? ? }, 2000);
? ? }
}

到此這篇關(guān)于JavaEE線程安全定時器模式任務(wù)的文章就介紹到這了,更多相關(guān)JavaEE 定時器 內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家!

相關(guān)文章

  • Spring MVC深入學(xué)習(xí)之啟動初始化過程

    Spring MVC深入學(xué)習(xí)之啟動初始化過程

    最近因為工作的原因在學(xué)習(xí)Spring MVC,為了更深入的學(xué)習(xí)Spring MVC,下面這篇文章主要給大家介紹了關(guān)于Spring MVC深入學(xué)習(xí)之啟動初始化過程的相關(guān)資料,文中通過示例代碼介紹的非常詳細(xì),對大家具有一定的參考學(xué)習(xí)價值,需要的朋友們下面來一起看看吧。
    2017-07-07
  • java Zookeeper簡述

    java Zookeeper簡述

    ZooKeeper是一個分布式的,開放源碼的分布式應(yīng)用程序協(xié)調(diào)服務(wù),是Google的Chubby一個開源的實現(xiàn),是Hadoop和Hbase的重要組件。下面通過本文給大家分享java 中 zookeeper簡單使用,需要的朋友參考下吧
    2021-09-09
  • 理解 MyBatis 是如何在 Spring 容器中初始化的

    理解 MyBatis 是如何在 Spring 容器中初始化的

    這篇文章主要介紹了理解 MyBatis 是如何在 Spring 容器中初始化的,文中通過示例代碼介紹的非常詳細(xì),對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧
    2020-11-11
  • Spring boot按日切分spring boot的nohup.out日志文件的方法

    Spring boot按日切分spring boot的nohup.out日志文件的方法

    過大的日志文件維護(hù)起來存在諸多問題,所以最好是能夠按日或按大小切分日志文件,下面小編給大家?guī)砹薙pring boot按日切分spring boot的nohup.out日志文件的方法,一起看看吧
    2018-08-08
  • Java經(jīng)典面試題最全匯總208道(三)

    Java經(jīng)典面試題最全匯總208道(三)

    這篇文章主要介紹了Java經(jīng)典面試題最全匯總208道(三),本文章內(nèi)容詳細(xì),該模塊分為了六個部分,本次為第三部分,需要的朋友可以參考下
    2023-01-01
  • JAVA使用commos-fileupload實現(xiàn)文件上傳與下載實例解析

    JAVA使用commos-fileupload實現(xiàn)文件上傳與下載實例解析

    這篇文章主要介紹了JAVA使用commos-fileupload實現(xiàn)文件上傳與下載的相關(guān)資料,需要的朋友可以參考下
    2016-02-02
  • 一文帶你看懂Java8中的lambda表達(dá)式和方法引用

    一文帶你看懂Java8中的lambda表達(dá)式和方法引用

    Lambda 表達(dá)式是 Java 8 引入的一項重要特性,它提供了一種簡潔、清晰且靈活的語法來表示可傳遞的匿名函數(shù),下面就跟隨小編一起學(xué)習(xí)一下Java8中的lambda表達(dá)式和方法引用的相關(guān)知識吧
    2023-12-12
  • 怎樣通過反射獲取非靜態(tài)內(nèi)部類實例

    怎樣通過反射獲取非靜態(tài)內(nèi)部類實例

    這篇文章主要介紹了怎樣通過反射獲取非靜態(tài)內(nèi)部類實例,具有很好的參考價值,希望對大家有所幫助。如有錯誤或未考慮完全的地方,望不吝賜教
    2023-03-03
  • Spring Validation和Hibernate Validator結(jié)合國際化代碼實例

    Spring Validation和Hibernate Validator結(jié)合國際化代碼實例

    這篇文章主要介紹了Spring Validation和Hibernate Validator結(jié)合國際化代碼實例,我們需要對請求參數(shù)進(jìn)行非空、長度、正確性進(jìn)行校驗, 本文主要講解Spring Validation 和 Hibernate Validator, 同時整合i18n(國際化)實現(xiàn)參數(shù)校驗自動,需要的朋友可以參考下
    2023-10-10
  • 詳解java代碼中init method和destroy method的三種使用方式

    詳解java代碼中init method和destroy method的三種使用方式

    這篇文章主要介紹了詳解java代碼中init method和destroy method的三種使用方式,文中通過示例代碼介紹的非常詳細(xì),對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧
    2020-03-03

最新評論