Java的PriorityBlockingQueue優(yōu)先級阻塞隊列代碼實例
PriorityBlockingQueue阻塞隊列
PriorityBlockingQueue顧名思義是帶有優(yōu)先級的阻塞隊列,為了實現(xiàn)按優(yōu)先級彈出數(shù)據(jù),存入其中的對象必須實現(xiàn)comparable接口自定義排序方法。
取出數(shù)據(jù)時會按照compareTo方法排序后的順序取出。
首先是定義實現(xiàn)comparable接口的類:
/** * 添加到優(yōu)先級隊列的對象需要自定義排序方法 * @author SN * */ public class Product implements Comparable<Product>{ private int id; private String name; @Override public int compareTo(Product product){ return this.id<product.id?-1:(this.id>product.id?1:0); } public int getId() { return id; } public void setId(int id) { this.id = id; } public String getName() { return name; } public void setName(String name) { this.name = name; } public String toString(){ return this.id+","+this.name; } }
然后是測試操作優(yōu)先級阻塞隊列:
import java.util.concurrent.PriorityBlockingQueue; public class PriorityQueueExp { //優(yōu)先級阻塞隊列添加的對象必須實現(xiàn)comparable接口才能進行排序 static PriorityBlockingQueue<Product> pbq=new PriorityBlockingQueue<>(); public static void main(String[] args) throws InterruptedException { Product p1=new Product(); p1.setId(1); p1.setName("數(shù)據(jù)1"); Product p2=new Product(); p2.setId(3); p2.setName("數(shù)據(jù)3"); Product p3=new Product(); p3.setId(2); p3.setName("數(shù)據(jù)2"); Product p4=new Product(); p4.setId(4); p4.setName("數(shù)據(jù)4"); pbq.add(p1); pbq.add(p2); pbq.add(p3); pbq.add(p4); System.out.println("隊列中的數(shù)據(jù):"+pbq); System.out.println("取出隊列中的第一個數(shù)據(jù)"+pbq.take().toString()); System.out.println("隊列中的數(shù)據(jù):"+pbq); Product p5=new Product(); p5.setId(1); p5.setName("數(shù)據(jù)1"); pbq.add(p5); Product p6=new Product(); p6.setId(6); p6.setName("數(shù)據(jù)6"); pbq.add(p6); System.out.println("隊列中的數(shù)據(jù):"+pbq); } }
值得注意的是,從打印結(jié)果看,數(shù)據(jù)插入隊列是按先進先出的順序插入的,并沒有在插入隊列時就提前排好序。在第一次取出數(shù)據(jù)后再次查看隊列中的數(shù)據(jù)會發(fā)現(xiàn),隊列中的數(shù)據(jù)已經(jīng)排好序,后面在進行任何插入、取出操作都會進行排序,因此可以得出優(yōu)先級阻塞隊列是延遲排序的,只有在第一次取出數(shù)據(jù)后才會進行排序。這樣應(yīng)該也是作者在設(shè)計優(yōu)先級隊列時進行的一個性能上的優(yōu)化。類似于類的延遲加載。
到此這篇關(guān)于Java的PriorityBlockingQueue優(yōu)先級阻塞隊列代碼實例的文章就介紹到這了,更多相關(guān)PriorityBlockingQueue阻塞隊列內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家!
相關(guān)文章
Canal搭建?idea設(shè)置及采集數(shù)據(jù)到kafka的操作方法
這篇文章主要介紹了Canal搭建idea設(shè)置及采集數(shù)據(jù)到kafka的相關(guān)知識,本文給大家介紹的非常詳細,對大家的學(xué)習(xí)或工作具有一定的參考借鑒價值,需要的朋友可以參考下2023-05-05基于jdk動態(tài)代理和cglib動態(tài)代理實現(xiàn)及區(qū)別說明
這篇文章主要介紹了基于jdk動態(tài)代理和cglib動態(tài)代理實現(xiàn)及區(qū)別說明,具有很好的參考價值,希望對大家有所幫助。如有錯誤或未考慮完全的地方,望不吝賜教2023-05-05基于Java實現(xiàn)多線程下載并允許斷點續(xù)傳
這篇文章主要介紹了基于Java實現(xiàn)多線程下載并允許斷點續(xù)傳,文中通過示例代碼介紹的非常詳細,對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友可以參考下2020-03-03Spring Boot監(jiān)聽Redis Key失效事件實現(xiàn)定時任務(wù)的示例
這篇文章主要介紹了Spring Boot監(jiān)聽Redis Key失效事件實現(xiàn)定時任務(wù)的示例,文中通過示例代碼介紹的非常詳細,對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2020-04-04springBoot項目中的static和templates文件夾的使用
本文主要介紹了springBoot項目中的static和templates文件夾的使用,文中通過示例代碼介紹的非常詳細,對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2024-07-07