完全队列上的java blockingqueue使用者块

Question

我正在编写一个小程序，将推特公共流中的推特信息放入HBase数据库。该程序使用两个线程，一个用于收集推文，另一个用于处理推文。第一个线程使用twitter4j StatusListener获取推文，并将其放入容量为100的ArrayBlockingQueue中。第二个线程从队列中获取状态，过滤所需的数据并将其移动到数据库中。处理要比收集状态花费更多的时间。

制作人如下所示：

public void onStatus(Status status) {
    try {
        this.queue.put(status);
    } catch(Exception ex) {
        ex.printStackTrace();
    }
}

使用者使用take并调用函数来处理新状态：

public void run() {
    try {
        while(true) {
            // Get new status to process
            this.status = this.queue.take();
            this.analyse();
        }
    } catch(Exception ex) {
        ex.printStackTrace();
    }
 }

在main函数中，创建并启动了两个线程：

ArrayBlockingQueue<Status> queue_public = new ArrayBlockingQueue<Status>(100);

Thread ta_public = new Thread(new TweetAnalyser(cl.getOptionValue("config"), queue_public));
Thread st_public = new Thread(new RunPublicStream(cl.getOptionValue("config"), queue_public));

ta_public.start();
st_public.start();

程序运行了一段时间没有出现任何问题，但随后突然停止。此时，队列已满，消费者似乎无法从队列中获取新状态。我尝试了几种不同的生产者/消费者模式，但没有成功。未引发异常。

我不知道我们在寻找失败。我希望有人能给我一个提示或解决方案。

Answer 1

如果使用阻塞队列，请仔细检查代码中的阻塞命令（对于ArrayBlockingQueue，请使用put和take），如果使用多个列表，请检查拼写错误。