BlockingQueue 和 TransferQueue 的区别

Question

我对 BlockingQueue/LinkedBlockingQueue 与 jsr166y 和 java 7 中的新 TransferQueue/LinkedTransferQueue 类型之间的区别有点困惑

Answer 1

来自 TransferQueue JavaDocs：

一个BlockingQueue，生产者可以在其中等待消费者接收元素。 TransferQueue 在消息传递应用程序中可能很有用，其中生产者有时（使用方法 transfer(E)）等待消费者调用 take 或 poll 接收元素，而有时将元素排入队列（通过方法 put）而不等待接收。

换句话说，当你使用BlockingQueue时，你只能将元素放入队列（如果队列已满则阻塞）。使用 TransferQueue，您还可以阻塞直到其他线程收到您的元素（您必须为此使用新的 transfer 方法）。这就是区别。使用 BlockingQueue，您不能等到其他线程删除您的元素（仅当您使用 SynchronousQueue 时，但这并不是真正的队列）。

除此之外，TransferQueue也是一个BlockingQueue。查看 TransferQueue 中新的可用方法： http:// /download.oracle.com/javase/7/docs/api/java/util/concurrent/TransferQueue.html（传输、tryTransfer、hasWaitingConsumer、getWaitingConsumerCount）。

---

Java SE 7 中的集合框架增强功能明确表示:

添加了TransferQueue接口。它是 BlockingQueue 接口的改进，生产者可以在其中等待消费者接收元素。此版本中还包含新接口的一种实现：LinkedTransferQueue。

Answer 2

简而言之，BlockingQueue 保证了生产者生成的元素必须在队列中，而 TransferQueue 则更进一步，它保证了该元素被某个消费者“消费”。

Answer 3

很久以前的一个问题，@Peter 的回答非常详尽。对于想了解 TransferQueue 在实际中如何工作的人，也许可以参考下面的现场演示。

import java.util.concurrent.LinkedTransferQueue;
import java.util.concurrent.TransferQueue;

public class TransferQueueExample {

    TransferQueue<String> queue = new LinkedTransferQueue<String>();

    class Producer implements Runnable{

        @Override
        public void run() {
            // TODO Auto-generated method stub
            for(int i = 0; i < 2; i++){
                try{
                    System.out.println("Producer waiting to transfer: " + i);
                    queue.transfer("" + i);
                    System.out.println("Producer transfered: " + i);
                }catch(Exception e){
                    e.printStackTrace();
                }
            }
        }

    }

    class Consumer implements Runnable{

        @Override
        public void run() {
            // TODO Auto-generated method stub
            for(int i = 0; i < 2; i++){
                try{
                    Thread.sleep(2000);
                    System.out.println("Consumer waiting to comsume: " + i);
                    queue.take();
                    System.out.println("Consumer consumed: " + i);
                }catch(Exception e){
                    e.printStackTrace();
                }
            }
        }
    }

    public static void main(String args[]){
        TransferQueueExample example = new TransferQueueExample();
        new Thread(example.new Producer()).start();
        new Thread(example.new Consumer()).start();
    }

}

输出是：

Producer waiting to transfer: 0
Consumer waiting to comsume: 0
Consumer consumed: 0
Producer transfered: 0
Producer waiting to transfer: 1
Consumer waiting to comsume: 1
Consumer consumed: 1
Producer transfered: 1

transfer 是差异发生的地方。

将元素传输给使用者，并在必要时等待。

更准确地说，如果存在则立即传输指定元素
存在一个消费者已经在等待接收它（在采取或定时
poll)，否则等待直到消费者接收到该元素。

与 javadoc 一样，传输 将等到消费者拿走产品为止。

这就是为什么首先调用 "Producer waiting to transfer: 0" ，大约 2 秒后，消费者收到后， Producer Transfered: 0 是然后打电话。

Answer 4

尽管似乎确实存在某种形式的性能差异；请参阅 ArrayBlockingQueue 与 LinkedTransferQueue 和朋友