這篇文章主要為大家展示了“java中TransferQueue的示例分析”，內(nèi)容簡而易懂，條理清晰，希望能夠幫助大家解決疑惑，下面讓小編帶領(lǐng)大家一起研究并學(xué)習(xí)一下“java中TransferQueue的示例分析”這篇文章吧。

站在用戶的角度思考問題，與客戶深入溝通，找到平遠(yuǎn)網(wǎng)站設(shè)計(jì)與平遠(yuǎn)網(wǎng)站推廣的解決方案，憑借多年的經(jīng)驗(yàn)，讓設(shè)計(jì)與互聯(lián)網(wǎng)技術(shù)結(jié)合，創(chuàng)造個(gè)性化、用戶體驗(yàn)好的作品，建站類型包括：網(wǎng)站設(shè)計(jì)、網(wǎng)站制作、企業(yè)官網(wǎng)、英文網(wǎng)站、手機(jī)端網(wǎng)站、網(wǎng)站推廣、域名與空間、網(wǎng)站空間、企業(yè)郵箱。業(yè)務(wù)覆蓋平遠(yuǎn)地區(qū)。

TransferQueue

TransferQueue(java7引入)繼承了BlockingQueue（BlockingQueue又繼承了Queue）并擴(kuò)展了一些新方法。生產(chǎn)者會(huì)一直阻塞直到所添加到隊(duì)列的元素被某一個(gè)消費(fèi)者所消費(fèi)（不僅僅是添加到隊(duì)列里就完事）。

LinkedTransferQueue

LinkedTransferQueue實(shí)際上是ConcurrentLinkedQueue、SynchronousQueue（公平模式）和LinkedBlockingQueue的超集。而且LinkedTransferQueue更好用，因?yàn)樗粌H僅綜合了這幾個(gè)類的功能，同時(shí)也提供了更高效的實(shí)現(xiàn)。

對(duì)比SynchronousQueue

SynchronousQueue使用兩個(gè)隊(duì)列（一個(gè)用于正在等待的生產(chǎn)者、另一個(gè)用于正在等待的消費(fèi)者）和一個(gè)用來保護(hù)兩個(gè)隊(duì)列的鎖。而LinkedTransferQueue使用CAS操作實(shí)現(xiàn)一個(gè)非阻塞的方法，這是避免序列化處理任務(wù)的關(guān)鍵。

使用場景

當(dāng)我們不想生產(chǎn)者過度生產(chǎn)消息時(shí)，TransferQueue可能非常有用，可避免發(fā)生OutOfMemory錯(cuò)誤。在這樣的設(shè)計(jì)中，消費(fèi)者的消費(fèi)能力將決定生產(chǎn)者產(chǎn)生消息的速度。

實(shí)例

public class LinkedTransferQueueDemo {
static LinkedTransferQueue lnkTransQueue = new LinkedTransferQueue();
public static void main(String[] args) {
ExecutorService exService = Executors.newFixedThreadPool(2);
Producer producer = new LinkedTransferQueueDemo().new Producer();
Consumer consumer = new LinkedTransferQueueDemo().new Consumer();
exService.execute(producer);
exService.execute(consumer);
exService.shutdown();
}
class Producer implements Runnable{
@Override
public void run() {
for(int i=0;i<3;i++){
try {
System.out.println("Producer is waiting to transfer...");
lnkTransQueue.transfer("A"+i);
System.out.println("producer transfered element: A"+i);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
}
class Consumer implements Runnable{
@Override
public void run() {
for(int i=0;i<3;i++){
try {
System.out.println("Consumer is waiting to take element...");
String s= lnkTransQueue.take();
System.out.println("Consumer received Element: "+s);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
}
}

輸出

Producer is waiting to transfer...
Consumer is waiting to take element...
producer transfered element: A0
Producer is waiting to transfer...
Consumer received Element: A0
Consumer is waiting to take element...
producer transfered element: A1
Producer is waiting to transfer...
Consumer received Element: A1
Consumer is waiting to take element...
Consumer received Element: A2
producer transfered element: A2

以上是“java中TransferQueue的示例分析”這篇文章的所有內(nèi)容，感謝各位的閱讀！相信大家都有了一定的了解，希望分享的內(nèi)容對(duì)大家有所幫助，如果還想學(xué)習(xí)更多知識(shí)，歡迎關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道！