使用ArrayList在Java中实现同步队列

Question

我一直在做一个需要同步队列的项目，因为我的程序是多线程的，线程可能会访问这个队列。我使用arraylist来实现这一点，但我似乎遇到了一些问题，线程陷入僵局。我不知道排队是否是原因，但我只是想检查一下：

public class URLQueue {
    private ArrayList<URL> urls;

    public URLQueue() {
        urls = new ArrayList<URL>();
    }

    public synchronized URL remove() throws InterruptedException {
        while (urls.isEmpty())
            wait();
        URL r = urls.remove(0);
        notifyAll();
        return r;
    }

    public synchronized void add(URL newURL) throws InterruptedException {
        urls.add(newURL);
        notifyAll();
    }

    public int getSize() {
        return urls.size();
    }
}

编辑：即使使用LinkedBlockingQueue，我也会陷入与之前相同的循环中。我认为这是因为有一个线程正在等待队列被填充，但它从来没有这样做，因为其他功能已经完成运行…有什么想法吗？？？

Answer 1

在您的代码中，notifyAll（） 不会引发中断异常，因此您应该从 add（） 中删除抛出

remove（） 方法不需要通知All（），因为它的操作不应该唤醒其他线程。

应该同步< code>getSize()方法。

否则，代码不可能死锁，因为需要两个锁来创建死锁。

Answer 2

最好在这里使用链接块队列，因为它是为此目的而设计的。它会等到某个元素可用，同时尝试删除一个 alement。

链接阻止队列

它提供了一个< code>take()方法

检索并删除此队列的头，如有必要，请等待元素变为可用