av一区二区在线观看_亚洲男人的天堂网站_日韩亚洲视频_在线成人免费_欧美日韩精品免费观看视频_久草视

您的位置:首頁技術文章
文章詳情頁

詳解Java中CountDownLatch異步轉同步工具類

瀏覽:86日期:2022-08-09 15:30:46
使用場景

由于公司業務需求,需要對接socket、MQTT等消息隊列。眾所周知 socket 是雙向通信,socket的回復是人為定義的,客戶端推送消息給服務端,服務端的回復是兩條線。無法像http請求有回復。下發指令給硬件時,需要校驗此次數據下發是否成功。用戶體驗而言,點擊按鈕就要知道此次的下發成功或失敗。

詳解Java中CountDownLatch異步轉同步工具類

如上圖模型,

第一種方案使用Tread.sleep優點:占用資源小,放棄當前cpu資源缺點: 回復速度快,休眠時間過長,仍然需要等待休眠結束才能返回,響應速度是固定的,無法及時響應第二種方案使用CountDownLatch

package com.lzy.demo.delay;import java.util.Map;import java.util.concurrent.ArrayBlockingQueue;import java.util.concurrent.ConcurrentHashMap;import java.util.concurrent.CountDownLatch;import java.util.concurrent.DelayQueue;import java.util.concurrent.Delayed;import java.util.concurrent.ExecutorService;import java.util.concurrent.ThreadPoolExecutor;import java.util.concurrent.TimeUnit;public class CountDownLatchPool { //countDonw池 private final static Map<Integer, CountDownLatch> countDownLatchMap = new ConcurrentHashMap<>(); //延遲隊列 private final static DelayQueue<MessageDelayQueueUtil> delayQueue = new DelayQueue<>(); private volatile static boolean flag =false; //單線程池 private final static ExecutorService t = new ThreadPoolExecutor(1, 1,0L, TimeUnit.MILLISECONDS,new ArrayBlockingQueue<>(1)); public static void addCountDownLatch(Integer messageId) {CountDownLatch countDownLatch = countDownLatchMap.putIfAbsent(messageId,new CountDownLatch(1) );if(countDownLatch == null){ countDownLatch = countDownLatchMap.get(messageId);}try { addDelayQueue(messageId); countDownLatch.await(3L, TimeUnit.SECONDS);} catch (InterruptedException e) { e.printStackTrace();}System.out.println('阻塞等待結束~~~~~~'); } public static void removeCountDownLatch(Integer messageId){CountDownLatch countDownLatch = countDownLatchMap.get(messageId);if(countDownLatch == null) return;countDownLatch.countDown();countDownLatchMap.remove(messageId);System.out.println('清除Map數據'+countDownLatchMap); } private static void addDelayQueue(Integer messageId){delayQueue.add(new MessageDelayQueueUtil(messageId));clearMessageId(); } private static void clearMessageId(){synchronized (CountDownLatchPool.class){ if(flag){return; } flag = true;}t.execute(()->{ while (delayQueue.size() > 0){System.out.println('進入線程并開始執行');try { MessageDelayQueueUtil take = delayQueue.take(); Integer messageId1 = take.getMessageId(); removeCountDownLatch(messageId1); System.out.println('清除隊列數據'+messageId1);} catch (InterruptedException e) { e.printStackTrace();} } flag = false; System.out.println('結束end----');}); } public static void main(String[] args) throws InterruptedException {/*測試超時清空mapnew Thread(()->addCountDownLatch(1)).start();new Thread(()->addCountDownLatch(2)).start();new Thread(()->addCountDownLatch(3)).start();*///提前創建線程,清空countdownnew Thread(()->{ try {Thread.sleep(500L);removeCountDownLatch(1); } catch (InterruptedException e) {e.printStackTrace(); }}).start();//開始阻塞addCountDownLatch(1); //通過調整上面的sleep我們發現阻塞市場取決于countDownLatch.countDown()執行時間 System.out.println('阻塞結束----'); }}class MessageDelayQueueUtil implements Delayed { private Integer messageId; private long avaibleTime; public Integer getMessageId() {return messageId; } public void setMessageId(Integer messageId) {this.messageId = messageId; } public long getAvaibleTime() {return avaibleTime; } public void setAvaibleTime(long avaibleTime) {this.avaibleTime = avaibleTime; } public MessageDelayQueueUtil(Integer messageId){this.messageId = messageId;//avaibleTime = 當前時間+ delayTime//重試3次,每次3秒+1秒的延遲this.avaibleTime=3000*3+1000 + System.currentTimeMillis(); } @Override public long getDelay(TimeUnit unit) {long diffTime= avaibleTime- System.currentTimeMillis();return unit.convert(diffTime,TimeUnit.MILLISECONDS); } @Override public int compareTo(Delayed o) {//compareTo用在DelayedUser的排序return (int)(this.avaibleTime - ((MessageDelayQueueUtil) o).getAvaibleTime()); }}

由于socket并不確定每次都會有數據返回,所以map的數據會越來越大,最終導致內存溢出需定時清除map內的無效數據。可以使用DelayedQuene延遲隊列來處理,相當于給對象添加一個過期時間

使用方法 addCountDownLatch 等待消息,異步回調消息清空removeCountDownLatch

到此這篇關于詳解Java中CountDownLatch異步轉同步工具類的文章就介紹到這了,更多相關CountDownLatch異步轉同步工具類內容請搜索好吧啦網以前的文章或繼續瀏覽下面的相關文章希望大家以后多多支持好吧啦網!

標簽: Java
相關文章:
主站蜘蛛池模板: а_天堂中文最新版地址 | 日韩成人精品视频 | 国产色网站 | 一区二区小视频 | 午夜影院在线观看版 | 激情小视频| 国产精品亚洲精品久久 | 国产视频中文字幕在线观看 | 久久一区二区视频 | 黄色在线免费网站 | 亚洲国产精品视频 | 天天天久久久 | 亚洲久在线| 成人av网站在线观看 | 在线观看av不卡 | 成人免费共享视频 | 91精品国产乱码久久久久久久久 | 欧美在线视频不卡 | 免费看黄视频网站 | 男人的天堂亚洲 | 久久99久久99久久 | 欧美一区2区三区3区公司 | 日本成人区 | 91久久北条麻妃一区二区三区 | 国产精品久久久久aaaa九色 | 黄色一级片视频 | 成人久草| 午夜免费影视 | 国产伦精品一区二区三区四区视频 | 日韩中文在线观看 | 九九久久久 | 国产成人精品免费 | 成人av播放| 亚洲欧美一区二区三区在线 | 亚洲 欧美 另类 综合 偷拍 | 欧美精品网站 | 久久国产精品无码网站 | 不卡av电影在线播放 | 日韩精品一区二区三区视频播放 | 九九热国产视频 | 97caoporn国产免费人人 |