您好,登錄后才能下訂單哦!
本篇內容主要講解“java高并發中的BlockingQueue分析”,感興趣的朋友不妨來看看。本文介紹的方法操作簡單快捷,實用性強。下面就讓小編來帶大家學習“java高并發中的BlockingQueue分析”吧!
BlockingQueue就是阻塞隊列。在某些情況下對阻塞隊列的訪問可能會造成阻塞。
會產生阻塞的情況有以下兩種:
當隊列滿之后,進行入隊操作;
當隊列空之后,進行出隊操作;
因此,當一個線程對一個隊列已滿的情況下進行入隊操作就會產生阻塞,除非有另一個線程進行出隊列操作。同樣當一個線程對一個空隊列進行出隊操作時也會被阻塞,除非有另一個線程進行入隊操作。
根據上面的特性可以知道,阻塞隊列是線程安全的。通常用在生產者消費者場景。
ArrayBlockingQueue是一個有界的阻塞隊列(容量有限),內部使用數組實現,以先進先出的方式存儲數據
DelayQueue阻塞的是內部元素,DelayQueue中的元素必須實現一個接口,是J.U.C中的Delay接口(繼承了Comparable接口)。DelayQueue中的元素需要進行排序。一般情況下按照元素過期時間的優先級進行排序。
DelayQueue的使用場景:定時關閉連接、緩存對象、超時處理等。
LinkedBlockingQueue的大小和配置是可選的,如果初始化時指定了一個大小,那么就是有邊界的;如果不指定大小,那么就是無邊界的(默認最大整型值,內部實現是一個鏈表)。也是以先進先出的方式存儲數據。
這是一個帶優先級的阻塞隊列,同時也是一個無邊界的隊列,但是有排序規則的。需要注意的是PriorityBlockingQueue是允許插入null(空對象)的。插入PriorityBlockingQueue的對象必須實現comparable接口,隊列優先級的排序規則就是按照對接口實現來定義的。
內部僅允許容納一個元素,當一個線程插入一個元素后就會被阻塞,除非元素被另一個線程消費。因此又稱之為同步隊列。是一個無界非緩存的隊列,準確的說他不存儲元素,只有等待元素取走之后才能放入。
到此,相信大家對“java高并發中的BlockingQueue分析”有了更深的了解,不妨來實際操作一番吧!這里是億速云網站,更多相關內容可以進入相關頻道進行查詢,關注我們,繼續學習!
免責聲明:本站發布的內容(圖片、視頻和文字)以原創、轉載和分享為主,文章觀點不代表本網站立場,如果涉及侵權請聯系站長郵箱:is@yisu.com進行舉報,并提供相關證據,一經查實,將立刻刪除涉嫌侵權內容。