您好,登錄后才能下訂單哦!
java中的消息隊(duì)列怎么利用多線程實(shí)現(xiàn)?相信很多沒有經(jīng)驗(yàn)的人對此束手無策,為此本文總結(jié)了問題出現(xiàn)的原因和解決方法,通過這篇文章希望你能解決這個問題。
1、定義一個隊(duì)列緩存池:
//static修飾的成員變量和成員方法獨(dú)立于該類的任何對象。也就是說,它不依賴類特定的實(shí)例,被類的所有實(shí)例共享。 private static List<Queue> queueCache = new LinkedList<Queue>();
2、定義隊(duì)列緩沖池最大消息數(shù),如果達(dá)到該值,那么隊(duì)列檢入將等待檢出低于該值時繼續(xù)進(jìn)行。
private Integer offerMaxQueue = 2000;
3、定義檢出線程,如果隊(duì)列緩沖池沒有消息,那么檢出線程會線程等待中
new Thread(){ public void run(){ while(true){ String ip = null; try { synchronized (queueCache) { Integer size = queueCache.size(); if(size==0){ //隊(duì)列緩存池沒有消息,等待。。。。 queueCache.wait(); } Queue queue = queueCache.remove(0); if(isIpLock(queueStr)){//假若這個是一個多應(yīng)用的分布式系統(tǒng),那么這個判斷應(yīng)該是分布式鎖,這里說的鎖不是線程停止,而是跳過該消息,滯后處理 queueCache.add(queue);該queue重新加入隊(duì)列緩沖池,滯后處理, continue; }else{ ;//這里是處理該消息的操作。 } size = queueCache.size(); if(size<offerMaxQueue&&size>=0){ queueCache.notifyAll();//在隊(duì)列緩存池不超過最大值的前提下,假若檢入正在等待中,那么那么讓他們排隊(duì)檢入。 } } } catch (Exception e) { e.printStackTrace(); }finally{ try {//檢出該消息隊(duì)列的鎖 unIpLock(queueStr); } catch (Execption e) {//捕獲異常,不能讓線程掛掉 e.printStackTrace(); } } } }.start();
4、檢入隊(duì)列
synchronized (queueCache) { while(true){ Integer size = queueCache.size(); if(size>=offerMaxQueue){ try { queueCache.wait(); continue;//繼續(xù)執(zhí)行等待中的檢入任務(wù)。 } catch (InterruptedException e) { e.printStackTrace(); } }//IF if(size<=offerMaxQueue&&size>0){ queueCache.notifyAll(); } break;//檢入完畢 }//while }
5、鎖方法實(shí)現(xiàn)
/** * 鎖 * @param ip * @return * @throws */ public Boolean isLock(String queueStr) { return this.redisManager.setnx(queueStr+"_lock", "LOCK", 10000)!=1; } //解鎖 public void unIpLock(String queueStr) { if(ip!=null){ this.redisManager.del(queueStr+"_lock"); // lock.unlock(); } }
看完上述內(nèi)容,你們掌握java中的消息隊(duì)列怎么利用多線程實(shí)現(xiàn)的方法了嗎?如果還想學(xué)到更多技能或想了解更多相關(guān)內(nèi)容,歡迎關(guān)注億速云行業(yè)資訊頻道,感謝各位的閱讀!
免責(zé)聲明:本站發(fā)布的內(nèi)容(圖片、視頻和文字)以原創(chuàng)、轉(zhuǎn)載和分享為主,文章觀點(diǎn)不代表本網(wǎng)站立場,如果涉及侵權(quán)請聯(lián)系站長郵箱:is@yisu.com進(jìn)行舉報(bào),并提供相關(guān)證據(jù),一經(jīng)查實(shí),將立刻刪除涉嫌侵權(quán)內(nèi)容。