java并發(fā)編程（21）：并發(fā)新特性—阻塞隊列和阻塞棧（含代碼）-編程開發(fā)技術(shù)

《java并發(fā)編程（21）：并發(fā)新特性—阻塞隊列和阻塞棧（含代碼）-編程開發(fā)技術(shù)》由會員上傳分享，免費在線閱讀，更多相關(guān)內(nèi)容在工程資料-天天文庫。

1、hva并發(fā)編程（21）：并發(fā)新特性一阻塞隊列和阻塞棧（含代碼）-編程開發(fā)技術(shù)Java并發(fā)編程（21）：并發(fā)新特性一阻塞隊列和阻塞棧（含代碼）原文出處：蘭亭風(fēng)雨阻塞隊列阻塞隊列是Java5并發(fā)新特性中的內(nèi)容，阻塞隊列的接口是java.util,concurrent.BlockingQueue,它有多個實現(xiàn)類:ArrayBlockingQueue>DclayQucuc、LinkcdBlockingQucuc、PriorityBlockingQucuc、SynchronousQucuc等，用法大同小異，具體可查看JDK文檔，這里簡

2、單舉例看下ArrayBlockingQueue,它實現(xiàn)了一個有界隊列，當隊列滿時，便會阻塞等待，直到有元素出隊，后續(xù)的元素才可以被加入隊列。看下面的例子:importjeivEi.util,concurrent.BlockingQucuc;importjava.util.concurrent.ArrayBlockingQueue;publicclassBlockingQueueTest{publicstaticvoidmain(String[]args)throwsIntcrruptcdExccption{BlockingQ

3、ueuebqueue=newArrayBlockingQueue(20);for(inti=0;i〈30;i++){//將指定元索添加割此隊列中bqueue.put(z，加入元素〃+i);System,out.println(，z向阻塞隊列中添加了元素:〃+i)；}System,out.println(，z程序到此運行結(jié)束，即將退出〃)；}輸出結(jié)果如下：ts0123456789601234567891111111111T::::::::::::::::::::心元元元元元元元元元元元元元元元元

4、元一兀元元⑷了了了了了了了了了了了了了了了了了了了了nnnnnnnnnnnnnnnnnnnu-DDi力力力力力力力力力力力力力力力力力力力力lomds占占占占占占占占占口口口口口口口口口B規(guī)洌例例例例例例例例例例例例例例例因列列Uja塞塞塞塞塞塞塞塞塞塞塞塞塞塞塞塞塞塞?塞塞JFFVFFVFFVFFVFFVFFVFT-±FT-±FT-±FT-±FT-±FT-±FT-±FT-±FT-±FT-±FTUFTUs>nrinrimlminrinrinrinrinrinrinrinrinrinrinrinrinrinrlnrinrl、r

5、lMiK;以Mi一円MiK;以MiK;以F以MiK;以MiK;以Mi_F以Mi一円MiK;以MiK;以MiK;以MiK;以MiK;以Mi_F以MiK;以MiK;以Mikn以Jkf;以J一F:句句句句句句句句句句句句句句句句句句句旬.UnF：>jauacBlockingQueueTest-jaua從執(zhí)行結(jié)果屮可以看出，由于隊列屮元索的數(shù)量限制在了20個，因此添加20個元素后，其他元素便在隊列外阻塞等待，程序并沒有終止。如果隊列已滿后，我們將隊首元素移出，并可以繼續(xù)向阻塞隊列屮添加元素，修改代碼如下：importjava.ut

6、il,concurrent.BlockingQucuc;importjava.util.concurrent.ArrayBlockingQueue;publicclassBlockingQueueTest{publicstaticvoidmain(String[]args)tbrowsIntcrruptcdExccption{BlockingQueuebqueue=newArrayBlockingQueue(20);for(inti二0;i<30;i++){//將指定元索添加到此隊列中bque

7、ue.put(，，z，+i);System,out.printlnC向阻塞隊列中添加了元素:〃if(i>18){//從隊列中獲取隊頭元素，并將其移出隊列System,out.printin(，z從阻塞隊列中移除元素：〃+}}System,out.println(，z程序到此運行結(jié)束,}}bqueue.take());即將退出一--〃)；執(zhí)行結(jié)果如下：從結(jié)果中可以看出，當添加了第20個元素后，我們從隊首移出一個元素，這樣便可以繼續(xù)向隊列中添加元索，之后每添加一個元素，便從將隊首元素移除，這樣程序便可以執(zhí)行結(jié)束。阻塞棧阻塞棧與阻

8、塞隊列相似，只是它是Java6中加入的新特性，阻塞棧的接口java.util,concurrent.BlockingDeque也冇很多實現(xiàn)類，使用方法也比較相似,具體查看JDK文檔。下面同樣給岀一個簡單的例子：importjava.util,concurrent.BlockingDeque