0

我想要一个SynchronousQueue从一个线程插入元素的地方put()，所以输入被阻塞，直到元素被另一个线程接收。

在另一个线程中，我执行大量计算，并且不时想要检查一个元素是否已经可用，并使用它。但似乎isEmpty()总是返回 true，即使另一个线程正在等待put()调用。

这怎么可能？这是示例代码：

@Test
public void testQueue() throws InterruptedException {
    final BlockingQueue<Integer> queue = new SynchronousQueue<Integer>();

    Thread t = new Thread(new Runnable() {
        @Override
        public void run() {
            while (true) {
                if (!queue.isEmpty()) {
                    try {
                        queue.take();
                        System.out.println("taken!");
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                }
                // do useful computations here (busy wait)
            }
        }
    });
    t.start();

    queue.put(1234);
    // this point is never reached!
    System.out.println("hello");
}

编辑： isEmpty() 和 peek() 都不起作用，必须使用 poll()。谢谢！

4

3 回答 3

6

来自http://java.sun.com/j2se/1.5.0/docs/api/java/util/concurrent/SynchronousQueue.html#put(E)：

isEmpty
public boolean isEmpty()
总是返回真。SynchronousQueue 没有内部容量。

（尚未对此进行详细研究，但您可能想看看poll或take代替）

于 2009-01-22T13:32:32.317 回答
1

除了蒂姆的回答——你在消费者线程中什么都不做，而是在一个紧密的循环中不断地调用 isEmpty() 。与其要求操作系统在有一些有用的事情要做之前不要运行它，而是消费者线程一直很忙。即使 isEmpty 正常工作，生产者线程也很少有机会运行。

您可以（如果 isEmpty() 确实有效，或者您切换到使用 poll()）在队列为空时让消费者在测试之间休眠一段时间，以便让生产者有机会运行，或者（最好）只是取出isEmpty() 测试并让线程以合理的方式阻塞在 take() 内的互斥锁上，而不是轮询。

于 2009-01-22T13:36:05.897 回答
1

您的代码看起来像您正在尝试进行民意调查。为什么不直接调用 poll() 方法呢？

于 2009-01-22T14:59:18.663 回答