通过实例了解java TransferQueue

网友投稿 366 2023-01-06


通过实例了解java TransferQueue

序言

本文主要简介一下TransferQueue。

TransferQueue

TransferQueue(java7引入)继承了BlockingQueue(BlockingQueue又继承了Queue)并扩展了一些新方法。生产者会一直阻塞直到所添加到队列的元素被某一个消费者所消费(不仅仅是添加到队列里就完事)。

LinkedTransferQueue

LinkedTransferQueue实际上是ConcurrentLinkedQueue、SynchronousQueue(公平模式)和LinkedBlockingQueue的超集。而且LinkedTransferQueue更好用,因为它不仅仅综合了这几个类的功能,同时也提供了更高效的实现。

对比SynchronousQueue

SynchronousQueue使用两个队列(一个用于正在等待的生产者、另一个用于正在等待的消费者)和一个用来保护两个队列的锁。而LinkedTransferQueue使用CAS操作实现一个非阻塞的方法,这是避免序列化处理任务的关键。

使用场景

当我们不想生产者过度生产消息时,TransferQueue可能非常有用,可避免发生OutOfMemory错误。在这样的设计中,消费者的消费能力将决定生产者产生消息的速度。

实例

public class LinkedTransferQueueDemo {

static LinkedTransferQueue lnkTransQueue = new LinkedTransferQueue();

public static void main(String[] args) {

ExecutorFrktaLcFuoService 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 ElementFrktaLcFuo: "+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


版权声明:本文内容由网络用户投稿,版权归原作者所有,本站不拥有其著作权,亦不承担相应法律责任。如果您发现本站中有涉嫌抄袭或描述失实的内容,请联系我们jiasou666@gmail.com 处理,核实后本网站将在24小时内删除侵权内容。

上一篇:深入了解为什么Java中只有值传递?
下一篇:做接口测试的常用工具(接口测试需要的工具)
相关文章

 发表评论

暂时没有评论,来抢沙发吧~