java高并发(十七)J.U.C之BlockingQueue
BlockingQueue就是阻塞隊列。在某些情況下對阻塞隊列的訪問可能會造成阻塞。
會產生阻塞的情況有以下兩種:
?因此,當一個線程對一個隊列已滿的情況下進行入隊操作就會產生阻塞,除非有另一個線程進行出隊列操作。同樣當一個線程對一個空隊列進行出隊操作時也會被阻塞,除非有另一個線程進行入隊操作。
? ? 根據上面的特性可以知道,阻塞隊列是線程安全的。通常用在生產者消費者場景。
實現類 ArrayBlockingQueue
? ? ArrayBlockingQueue是一個有界的阻塞隊列(容量有限),內部使用數組實現,以先進先出的方式存儲數據
實現類DelayQueue
? ? DelayQueue阻塞的是內部元素,DelayQueue中的元素必須實現一個接口,是J.U.C中的Delay接口(繼承了Comparable接口)。DelayQueue中的元素需要進行排序。一般情況下按照元素過期時間的優先級進行排序。
? ? DelayQueue的使用場景:定時關閉連接、緩存對象、超時處理等。
實現類LinkedBlockingQueue
LinkedBlockingQueue的大小和配置是可選的,如果初始化時指定了一個大小,那么就是有邊界的;如果不指定大小,那么就是無邊界的(默認最大整型值,內部實現是一個鏈表)。也是以先進先出的方式存儲數據。
實現類PriorityBlockingQueue
這是一個帶優先級的阻塞隊列,同時也是一個無邊界的隊列,但是有排序規則的。需要注意的是PriorityBlockingQueue是允許插入null(空對象)的。插入PriorityBlockingQueue的對象必須實現comparable接口,隊列優先級的排序規則就是按照對接口實現來定義的。
實現類SynchronousQueue
內部僅允許容納一個元素,當一個線程插入一個元素后就會被阻塞,除非元素被另一個線程消費。因此又稱之為同步隊列。是一個無界非緩存的隊列,準確的說他不存儲元素,只有等待元素取走之后才能放入。
總結
以上是生活随笔為你收集整理的java高并发(十七)J.U.C之BlockingQueue的全部內容,希望文章能夠幫你解決所遇到的問題。
- 上一篇: java高并发(十六)J.U.C之For
- 下一篇: java高并发(十八)线程池