java - 为什么 java TransferQueue 在 "transfer()"之后不能 "put()"？

Question

我有一个非常简单的代码片段:

public static void main(String [] args) throws InterruptedException {
    TransferQueue<Integer> transferQueue = new LinkedTransferQueue<>();
    System.out.println("Step1");
    transferQueue.put(2);
    System.out.println("Step2");
    transferQueue.transfer(2);
    System.out.println("Step3");
}

运行这个程序，它打印:

Step1
Step2

然后卡在那里。那么为什么“transfer()”函数不起作用？

Answer 1

这由 javadoc 解释对于 transfer(e) 方法。

More precisely, transfers the specified element immediately if there exists a consumer already waiting to receive it (in take() or timed poll), else inserts the specified element at the tail of this queue and waits until the element is received by a consumer.

强调已添加!

在您的示例中，没有消费者接收元素，因此 transfer(2) 调用永远阻塞。

(这与前面的 put(2) 调用无关。)