色综合图-色综合图片-色综合图片二区150p-色综合图区-玖玖国产精品视频-玖玖香蕉视频

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

Java特性隊列和棧的堵塞原理解析

瀏覽:6日期:2022-08-22 14:22:47

做消息通信,消息會不斷從網絡流中取得,而后臺也有線程不斷消費。本來我一直是使用一些線程安全標識或方法來控制,后來在網上找到一些java新特性,里面包含了可以用到的堆棧使用,而且是堵塞的,這樣至少可以保證一些安全性。

對于堆:

BlockingQueue 不接受 null 元素。試圖 add、put 或 offer 一個 null 元素時,某些實現會拋出 NullPointerException。null 被用作指示 poll 操作失敗的警戒值。

BlockingQueue 可以是限定容量的。它在任意給定時間都可以有一個 remainingCapacity,超出此容量,便無法無阻塞地 put 附加元素。沒有任何內部容量約束的 BlockingQueue 總是報告 Integer.MAX_VALUE 的剩余容量。

BlockingQueue 實現主要用于生產者-使用者隊列,但它另外還支持 Collection接口。因此,舉例來說,使用 remove(x) 從隊列中移除任意一個元素是有可能的。然而,這種操作通常不 會有效執行,只能有計劃地偶爾使用,比如在取消排隊信息時。

BlockingQueue 實現是線程安全的。所有排隊方法都可以使用內部鎖或其他形式的并發控制來自動達到它們的目的。然而,大量的 Collection 操作(addAll、containsAll、retainAll 和 removeAll)沒有 必要自動執行,除非在實現中特別說明。因此,舉例來說,在只添加了 c 中的一些元素后,addAll(c) 有可能失敗(拋出一個異常)。

看一段代碼:

package com.test; import java.util.concurrent.ArrayBlockingQueue; import java.util.concurrent.BlockingQueue; /** * @說明 堵塞隊列和棧的使用 */ public class Test { @SuppressWarnings('unchecked') public static void main(String[] args) throws InterruptedException { BlockingQueue bqueue = new ArrayBlockingQueue(5); for (int i = 0; i < 10; i++) { // 添加元素到隊列,如果沒有可用空間,將一直等待(如果有必要) bqueue.put(i); System.out.println('添加了元素:' + i); } System.out.println('----End----'); } }

運行效果:

添加了元素:0 添加了元素:1 添加了元素:2 添加了元素:3 添加了元素:4

之后就會一直等待。

對于棧:

BlockingDeque 方法有四種形式,使用不同的方式處理無法立即滿足但在將來某一時刻可能滿足的操作:第一種方式拋出異常;第二種返回一個特殊值(null 或 false,具體取決于操作);第三種無限期阻塞當前線程,直至操作成功;第四種只阻塞給定的最大時間,然后放棄。

看一個例子:

package com.test; import java.util.concurrent.BlockingDeque; import java.util.concurrent.LinkedBlockingDeque; /** * @說明 堵塞隊列和棧的使用 */ public class Test { @SuppressWarnings('unchecked') public static void main(String[] args) throws InterruptedException { BlockingDeque bDeque = new LinkedBlockingDeque(5); for (int i = 0; i < 10; i++) { // 將指定元素添加到此阻塞棧中,如果沒有可用空間,將一直等待(如果有必要)。 bDeque.putFirst(i); System.out.println('添加了元素:' + i); } System.out.println('----End----'); } }

運行結果和堆一樣,也會產生等待。

對于兩者的解釋:

阻塞隊列的概念是,一個指定長度的隊列,如果隊列滿了,添加新元素的操作會被阻塞等待,直到有空位為止。同樣,當隊列為空時候,請求隊列元素的操作同樣會阻塞等待,直到有可用元素為止。

對于阻塞棧,與阻塞隊列相似。不同點在于棧是“后入先出”的結構,每次操作的是棧頂,而隊列是“先進先出”的結構,每次操作的是隊列頭。

注意的是,BlockingQueue是5中的特性,jdk6以后才增加了BlockingDeque。

以上就是本文的全部內容,希望對大家的學習有所幫助,也希望大家多多支持好吧啦網。

標簽: Java
相關文章:
主站蜘蛛池模板: 国产乱肥老妇精品视频 | 欧美亚洲国产精品久久久久 | 亚洲午夜网站 | 中文字幕在线观看一区二区三区 | 欧美日韩亚洲成色二本道三区 | 久久免费看 | 欧美性群另类交 | 国产精品久久久久久久人热 | 日本一区二区三区不卡视频中文字幕 | 亚洲2020天天堂在线观看 | 国产色a| 夜夜骚视频 | 波多野结衣在线不卡 | 亚洲天堂黄 | 欧美精品国产精品 | 香蕉网站狼人久久五月亭亭 | 美女被躁爽死 | 九九久久免费视频 | 欧美一级www片免费观看 | 久久久久久久99久久久毒国产 | a级淫片| 免费一级欧美大片在线观看 | 国产99视频精品免视看9 | 美女张开腿让人捅 | 精品欧美一区二区三区四区 | 91成人在线免费视频 | 欧美一级高清免费播放 | 正能量www正能量免费网站 | 免费高清一级欧美片在线观看 | 国产成人aa在线视频 | 97视频免费在线观看 | www亚洲视频 | 久久这里只有精品免费视频 | 日韩一级免费视频 | 亚洲国产爱久久全部精品 | 成人在线网址 | 欧美精品v欧洲精品 | videosfree性欧美另类 | 免费三级网站 | 亚洲 欧美 手机 在线观看 | 一级毛片美国 |