国产成人精品久久免费动漫-国产成人精品天堂-国产成人精品区在线观看-国产成人精品日本-a级毛片无码免费真人-a级毛片毛片免费观看久潮喷

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

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
相關文章:
主站蜘蛛池模板: 久草在线网站 | 全部免费的毛片在线看美国 | 国内黄色精品 | 午夜嘿咻| 国产一区中文字幕在线观看 | 国产亚洲欧美另类久久久 | 日韩加勒比在线 | 精品国产香蕉在线播出 | 免费观看成人毛片 | 亚洲国产日韩成人综合天堂 | 美国三级视频 | 久久久久久久国产精品毛片 | 日韩中文字幕在线亚洲一区 | 一区二区三区高清不卡 | 日韩一区二区在线免费观看 | 久久se精品一区精品二区 | 国产三级在线观看免费 | 国产视频一二三 | 国产真实女人一级毛片 | 91综合精品网站久久 | 天天澡天天碰天天狠伊人五月 | 久久午夜影院 | 精品色视频 | 失禁h啪肉尿出来高h健身房 | 久久久国产精品免费看 | 男人的亚洲天堂 | 欧美精品国产一区二区三区 | 国产香蕉在线视频一级毛片 | 久久国内精品自在自线软件 | 欧美区一区二区三 | 在线观看国产精品入口 | 日本 亚洲 欧美 | 国产在线精品福利91香蕉 | 久久久久久久久久毛片精品美女 | 免费人成黄页网站在线观看 | 男人天堂怡红院 | 美女黄频免费看 | 久久久久久久久久久视频国内精品视频 | 日本一区二区三区四区公司 | 日韩美女一级片 | a大片久久爱一级 |