java中PriorityBlockingQueue的入隊知識點總結
在PriorityBlockingQueue中添加元素同樣有四種方法,因為是樹狀的結構,所以在插入方法上也有所變化,是自下而上的操作過程。在入隊的規(guī)則上有三個要點需要我們注意。鑒于PriorityBlockingQueue入隊方法主要通過offer(E)實現(xiàn),所以我們就這種方法作主要講解。
1.入隊規(guī)則(1)默認的插入規(guī)則中,新加入的元素可能會破壞小頂堆的性質(zhì),因此需要進行調(diào)整。
(2)調(diào)整的過程為:從尾部下標的位置開始,將加入的元素逐層與當前點的父節(jié)點的內(nèi)容進行比較并交換,直到滿足父節(jié)點內(nèi)容都小于子節(jié)點的內(nèi)容為止。
(3)默認的刪除調(diào)整中,首先獲取頂部下標和最尾部的元素內(nèi)容,從頂部的位置開始,將尾部元素的內(nèi)容逐層向下與當前點的左右子節(jié)點中較小的那個交換,直到判斷元素內(nèi)容小于或等于左右子節(jié)點中的任何一個為止。
2.入隊方法入隊方法有:add(E), put(E), offer(E, timeout, TimeUnit), offer(E)
public void put(E e) { offer(e); // never need to block}public boolean offer(E e) { //判斷是否為空 if (e == null) throw new NullPointerException(); //顯示鎖 final ReentrantLock lock = this.lock; lock.lock(); //定義臨時對象 int n, cap; Object[] array; //判斷數(shù)組是否滿了 while ((n = size) >= (cap = (array = queue).length)) //數(shù)組擴容 tryGrow(array, cap); try { //拿到比較器 Comparator<? super E> cmp = comparator; //判斷是否有自定義比較器 if (cmp == null) //堆上浮 siftUpComparable(n, e, array); else //使用自定義比較器進行堆上浮 siftUpUsingComparator(n, e, array, cmp); //隊列長度 +1 size = n + 1; //喚醒休眠的出隊線程 notEmpty.signal(); } finally { //釋放鎖 lock.unlock(); } return true;}
可以看出前三個方法內(nèi)部都是通過 offer(e) 方法實現(xiàn)的。
相關文章:
