本篇文章為大家展示了linkedblockingqueue如何在java中使用,內(nèi)容簡明扼要并且容易理解,絕對(duì)能使你眼前一亮,通過這篇文章的詳細(xì)介紹希望你能有所收獲。
我們提供的服務(wù)有:成都網(wǎng)站設(shè)計(jì)、成都網(wǎng)站建設(shè)、外貿(mào)網(wǎng)站建設(shè)、微信公眾號(hào)開發(fā)、網(wǎng)站優(yōu)化、網(wǎng)站認(rèn)證、汾陽ssl等。為上千多家企事業(yè)單位解決了網(wǎng)站和推廣的問題。提供周到的售前咨詢和貼心的售后服務(wù),是有科學(xué)管理、有技術(shù)的汾陽網(wǎng)站制作公司
Java的特點(diǎn)有哪些 1.Java語言作為靜態(tài)面向?qū)ο缶幊陶Z言的代表,實(shí)現(xiàn)了面向?qū)ο罄碚?,允許程序員以優(yōu)雅的思維方式進(jìn)行復(fù)雜的編程。 2.Java具有簡單性、面向?qū)ο?、分布式、安全性、平臺(tái)獨(dú)立與可移植性、動(dòng)態(tài)性等特點(diǎn)。 3.使用Java可以編寫桌面應(yīng)用程序、Web應(yīng)用程序、分布式系統(tǒng)和嵌入式系統(tǒng)應(yīng)用程序等。
1.put方法使用事項(xiàng)
(1)使用putLock加鎖;
(2)如果隊(duì)列滿了就阻塞在notFull條件上;
(3)否則就入隊(duì);
(4)如果入隊(duì)后元素?cái)?shù)量小于容量,喚醒其它阻塞在notFull條件上的線程;
(5)釋放鎖;
(6)如果放元素之前隊(duì)列長度為0,就喚醒notEmpty條件;
2.put增加元素實(shí)例
public void put(E e) throws InterruptedException { if (e == null) throw new NullPointerException(); //e不能為null int c = -1; Node<E> node = new Node<E>(e); final ReentrantLock putLock = this.putLock; //獲取put鎖 final AtomicInteger count = this.count; //獲取count putLock.lockInterruptibly(); try { while (count.get() == capacity) { //如果滿了,那么就需要使用notFull阻塞 notFull.await(); } enqueue(node); c = count.getAndIncrement(); if (c + 1 < capacity) //如果此時(shí)又有空間了,那么notFull喚醒 notFull.signal(); } finally { putLock.unlock(); //釋放鎖 } if (c == 0) //當(dāng)c為0時(shí)候,也要根take鎖說一下,并發(fā)下 signalNotEmpty(); //調(diào)用notEmpty } public E take() throws InterruptedException { E x; int c = -1; final AtomicInteger count = this.count; final ReentrantLock takeLock = this.takeLock; // 使用takeLock加鎖 takeLock.lockInterruptibly(); try { // 如果隊(duì)列無元素,則阻塞在notEmpty條件上 while (count.get() == 0) { notEmpty.await(); } // 否則,出隊(duì) x = dequeue(); // 獲取出隊(duì)前隊(duì)列的長度 c = count.getAndDecrement(); // 如果取之前隊(duì)列長度大于1,則喚醒notEmpty if (c > 1) notEmpty.signal(); } finally { // 釋放鎖 takeLock.unlock(); } // 如果取之前隊(duì)列長度等于容量 // 則喚醒notFull if (c == capacity) signalNotFull(); return x; } private E dequeue() { // head節(jié)點(diǎn)本身是不存儲(chǔ)任何元素的 // 這里把head刪除,并把head下一個(gè)節(jié)點(diǎn)作為新的值 // 并把其值置空,返回原來的值 Node<E> h = head; Node<E> first = h.next; h.next = h; // help GC head = first; E x = first.item; first.item = null; return x; } private void signalNotFull() { final ReentrantLock putLock = this.putLock; putLock.lock(); try { // 喚醒notFull notFull.signal(); } finally { putLock.unlock(); } }
上述內(nèi)容就是linkedblockingqueue如何在java中使用,你們學(xué)到知識(shí)或技能了嗎?如果還想學(xué)到更多技能或者豐富自己的知識(shí)儲(chǔ)備,歡迎關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道。
網(wǎng)頁標(biāo)題:linkedblockingqueue如何在java中使用
URL標(biāo)題:http://chinadenli.net/article8/jsisip.html
成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián),為您提供、網(wǎng)站內(nèi)鏈、服務(wù)器托管、品牌網(wǎng)站設(shè)計(jì)、響應(yīng)式網(wǎng)站、靜態(tài)網(wǎng)站
聲明:本網(wǎng)站發(fā)布的內(nèi)容(圖片、視頻和文字)以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主,如果涉及侵權(quán)請(qǐng)盡快告知,我們將會(huì)在第一時(shí)間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng),如需處理請(qǐng)聯(lián)系客服。電話:028-86922220;郵箱:631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載,或轉(zhuǎn)載時(shí)需注明來源: 創(chuàng)新互聯(lián)