通过实例了解java TransferQueue
序言
本文主要简介一下TransferQueue。
TransferQueue
TransferQueue(java7引入)继承了BlockingQueue（BlockingQueue又继承了Queue）并扩展了一些新方法。生产者会一直阻塞直到所添加到队列的元素被某一个消费者所消费（不仅仅是添加到队列里就完事）。
LinkedTransferQueue
LinkedTransferQueue实际上是ConcurrentLinkedQueue、SynchronousQueue（公平模式）和LinkedBlockingQueue的超集。而且LinkedTransferQueue更好用，因为它不仅仅综合了这几个类的功能，同时也提供了更高效的实现。
对比SynchronousQueue
SynchronousQueue使用两个队列（一个用于正在等待的生产者、另一个用于正在等待的消费者）和一个用来保护两个队列的锁。而LinkedTransferQueue使用CAS操作实现一个非阻塞的方法，这是避免序列化处理任务的关键。
使用场景
当我们不想生产者过度生产消息时，TransferQueue可能非常有用，可避免发生OutOfMemory错误。在这样的设计中，消费者的消费能力将决定生产者产生消息的速度。
实例
publicclassLinkedTransferQueueDemo{
staticLinkedTransferQueuelnkTransQueue=newLinkedTransferQueue();
publicstaticvoidmain(String[]args){
ExecutorServiceexService=Executors.newFixedThreadPool(2);
Producerproducer=newLinkedTransferQueueDemo().newProducer();
Consumerconsumer=newLinkedTransferQueueDemo().newConsumer();
exService.execute(producer);
exService.execute(consumer);
exService.shutdown();
}
classProducerimplementsRunnable{
@Override
publicvoidrun(){
for(inti=0;i<3;i++){
try{
System.out.println("Produceriswaitingtotransfer...");
lnkTransQueue.transfer("A"+i);
System.out.println("producertransferedelement:A"+i);
}catch(InterruptedExceptione){
e.printStackTrace();
}
}
}
}
classConsumerimplementsRunnable{
@Override
publicvoidrun(){
for(inti=0;i<3;i++){
try{
System.out.println("Consumeriswaitingtotakeelement...");
Strings=lnkTransQueue.take();
System.out.println("ConsumerreceivedElement:"+s);
}catch(InterruptedExceptione){
e.printStackTrace();
}
}
}
}
}
输出
Produceriswaitingtotransfer... Consumeriswaitingtotakeelement... producertransferedelement:A0 Produceriswaitingtotransfer... ConsumerreceivedElement:A0 Consumeriswaitingtotakeelement... producertransferedelement:A1 Produceriswaitingtotransfer... ConsumerreceivedElement:A1 Consumeriswaitingtotakeelement... ConsumerreceivedElement:A2 producertransferedelement:A2
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持毛票票。