快捷導(dǎo)航

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

更新時(shí)間：2022年06月20日 11:08:54 作者：sugar?high

這篇文章主要介紹了JavaEE線程安全定時(shí)器模式任務(wù)，定時(shí)器模式像是一個(gè)鬧鐘定時(shí)，在一定時(shí)間之后被喚醒并執(zhí)行某個(gè)之前設(shè)定好的任務(wù)，感興趣的小伙伴可以參考一下

前言

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

public class 定時(shí)器 {
? ? 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)建一個(gè)專門的類來表示一個(gè)定時(shí)器的任務(wù)TimerTask，這個(gè)MyTask類的比較規(guī)則不是默認(rèn)存在的，需要我們手動(dòng)指定按照時(shí)間大小來比較的。

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

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

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

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

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

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

public class 定時(shí)器 {
? ? 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線程安全定時(shí)器模式任務(wù)的文章就介紹到這了,更多相關(guān)JavaEE 定時(shí)器內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: