为什么在将ArrayBlockingQueue放入列表后导致它为空队列？

Question

这是我第一次在StackOverflow上提问。我遇到的问题如下：

我有一个生产者和消费者类。在Producer类中，我逐行读取一个文件，并将这些文本行放入字符串列表中。当列表中的行数为x时。此列表被添加到ArrayBlockingQueue。我有一个在主线程中启动的生产者线程。除此之外，我还启动了一些Consumer线程。消费者线程从队列中获取一个项目，该项目应该是一个列表，并遍历此行列表以查找特定单词。找到单词后，它会增加一个计数变量。

发生的事情是，当消费者从队列中取出一个项目时，它说它是空的。我不知道为什么，因为我的制作人当然应该将其添加到队列中。

我的代码如下所示：

消费类：

public static class Consumer implements Callable<Integer> {

    int count = 0;

    @Override

    public Integer call() throws Exception {

        List<String> list = new ArrayList<>();

        list = arrayBlockingQueueInput.take();

        do {

            if (!list.isEmpty()){

                for (int i = 0; i < arrayBlockingQueueInput.take().size(); i++) {

                    for (String element : list.get(i).split(" ")) {

                        if (element.equalsIgnoreCase(findWord)) {

                            count++;

                        }

                    }

                }

            } else {

                arrayBlockingQueueInput.put(list);

            }

        } while (list.get(0) != "HALT");

        return count;

    }

}

谁能解释为什么会这样？我想补充一点，我们尝试使用毒药来告知消费者生产者处于暂停状态。

要回答我们为什么要这样做的问题？对于学校，我们尝试并行处理某个编程问题。我们选择的问题是字符串匹配。我们首先提出了串行解决方案和并行解决方案。对于下一个作业，我们必须改进并行解决方案，而老师告诉我们，这是一种实现方法。

Answer 1

您将列表添加到队列中并清除它：arrayBlockingQueueInput.put(results); results.clear();您需要执行以下操作将列表副本添加到队列中，以免clear()清理队列中的列表：arrayBlockingQueueInput.put(new&nbsp;ArrayList<String>(results)); results.clear();