java并發(fā)編程學(xué)習(xí)之DelayQueue

miqt 發(fā)布于2019-08-19 10:14 / 1408人閱讀

摘要：示例模擬五秒鐘后獲取信息必須實現(xiàn)接口存活時間加當(dāng)前時間剩余時間

示例

模擬五秒鐘后獲取信息

public class DelayQueueDemo {
    static class DelayedVo implements Delayed {//必須實現(xiàn)Delayed接口
        private long activeTime;
        private String name;

        public DelayedVo(String name, long activeTime) {
            this.name = name;
            this.activeTime = TimeUnit.NANOSECONDS.convert(activeTime, TimeUnit.MILLISECONDS) + System.nanoTime();//存活時間加當(dāng)前時間
        }

        @Override
        public long getDelay(TimeUnit unit) {
            return unit.convert(activeTime - System.nanoTime(), TimeUnit.NANOSECONDS);//剩余時間
        }

        @Override
        public int compareTo(Delayed o) {
            long t = getDelay(TimeUnit.NANOSECONDS) - o.getDelay(TimeUnit.NANOSECONDS);
            return t == 0 ? 0 : (t > 0 ? 1 : -1);
        }

        public String getName() {
            return name;
        }
    }
    static class ReadThread implements Runnable {
        private DelayQueue queue;

        public ReadThread(DelayQueue queue) {
            this.queue = queue;
        }

        @Override
        public void run() {
            try {
                DelayedVo delayedVo = queue.take();
                System.out.println(delayedVo.getName());
            } catch (InterruptedException e) {
                e.printStackTrace();
            }

        }
    }

    static class WriteThread implements Runnable {
        private DelayQueue queue;

        public WriteThread(DelayQueue queue) {
            this.queue = queue;
        }

        @Override
        public void run() {
            DelayedVo delayedVo = new DelayedVo("abc", 5000);
            queue.put(delayedVo);
        }
    }

    public static void main(String[] args) {
        DelayQueue queue =new DelayQueue<> ();
        new Thread(new WriteThread(queue)).start();
        new Thread(new ReadThread(queue)).start();
    }
}

GPU云服務(wù)器云服務(wù)器學(xué)習(xí)之substr() 深度學(xué)習(xí)之概要 webrtc學(xué)習(xí)之九 linux學(xué)習(xí)之centos

文章版權(quán)歸作者所有，未經(jīng)允許請勿轉(zhuǎn)載,若此文章存在違規(guī)行為，您可以聯(lián)系管理員刪除。

轉(zhuǎn)載請注明本文地址：http://www.ezyhdfw.cn/yun/75676.html

相關(guān)文章

java并發(fā)編程學(xué)習(xí)之阻塞隊列

摘要：是線程安全的存取隊列，繼承了。接口插入方法阻塞隊列滿了，拋出異常。如果隊列不為空，返回頭結(jié)點(diǎn)但不刪除，如果隊列為空，返回子類一個由數(shù)組結(jié)構(gòu)組成的有界阻塞隊列。一個由鏈表結(jié)構(gòu)組成的有界阻塞隊列。一個支持優(yōu)先級排序的無界阻塞隊列。 BlockingQueue BlockingQueue是線程安全的存取隊列，繼承了Queue。使用場景消費(fèi)者生產(chǎn)者模式。生產(chǎn)者，一直會往隊列里扔數(shù)據(jù)，直...

YJNldm 2019-08-19 10:15 評論0 收藏0
java并發(fā)編程學(xué)習(xí)之synchronize（一）

摘要：線程安全問題在并發(fā)編程學(xué)習(xí)之基礎(chǔ)概念提到，多線程的劣勢之一，有個線程安全問題，現(xiàn)在看看下面的例子。那么，該怎么解決呢，很簡單，在方法前加個同步鎖。運(yùn)行結(jié)果如下有兩種情況，是因為看誰先搶占鎖，但是輸出的算法結(jié)果是正確的。線程安全問題在java并發(fā)編程學(xué)習(xí)之基礎(chǔ)概念提到，多線程的劣勢之一，有個線程安全問題，現(xiàn)在看看下面的例子。 public class NotSafeDemo { ...

Elle 2019-08-16 18:28 評論0 收藏0
java并發(fā)編程學(xué)習(xí)之再談公平鎖和非公平鎖

摘要：在并發(fā)編程學(xué)習(xí)之顯示鎖里有提過公平鎖和非公平鎖，我們知道他的使用方式，以及非公平鎖的性能較高，在源碼分析的基礎(chǔ)上，我們看看和的區(qū)別在什么地方。而非公平鎖直接嘗試獲取鎖。在java并發(fā)編程學(xué)習(xí)之顯示鎖Lock里有提過公平鎖和非公平鎖，我們知道他的使用方式，以及非公平鎖的性能較高，在AQS源碼分析的基礎(chǔ)上，我們看看NonfairSync和FairSync的區(qū)別在什么地方。 lock方法 ...

warkiz 2019-08-19 11:48 評論0 收藏0
java并發(fā)編程學(xué)習(xí)之FutureTask

摘要：在并發(fā)編程學(xué)習(xí)之三種線程啟動方式中有提過。是否執(zhí)行結(jié)束，包括正常執(zhí)行結(jié)束或異常結(jié)束。獲取返回值，沒有得到返回值前一直阻塞。運(yùn)行結(jié)果如下由于任務(wù)被取消，所以拋出異常。注意的是，此時線程還在跑，和返回的是。并不能讓任務(wù)真正的結(jié)束。 FutureTask 在java并發(fā)編程學(xué)習(xí)之三種線程啟動方式中有提過。主要的方法如下： cancel(boolean mayInterruptIfRunni...

BothEyes1993 2019-08-16 18:33 評論0 收藏0
java并發(fā)編程學(xué)習(xí)之Volatile

摘要：但是的語義不足以確保遞增操作的原子性，在多線程的情況下，線程不一定是安全的。檢查某個狀態(tài)標(biāo)記，以判斷是否退出循環(huán)某個方法這邊和用普通的變量的區(qū)別是，在多線程的情況下，取到后，的值被改變了，判斷會不正確。多線程為什么是不安全的這邊簡單的講述一下，參考java并發(fā)編程學(xué)習(xí)之synchronize（一）當(dāng)線程A和線程B同時進(jìn)入num = num + value; 線程A會把num的值...

thekingisalwaysluc 2019-08-16 18:28 評論0 收藏0