java - 具有线程和阻塞队列的消费者-生产者

Question

我编写了一个类“Producer”，它连续解析特定文件夹中的文件。解析的结果将存储在Consumer的队列中。

public class Producer extends Thread
{ 
    private BlockingQueue<MyObject> queue;
    ...
    public void run()
    {
        while (true)
        {
        //Store email attachments into directory
        ...
        //Fill the queue
        queue.put(myObject);


        sleep(5*60*1000);
        }
    }
}

我的消费者类正在连续检查队列中是否有可用的内容。如果是这样，它正在对解析结果执行一些工作。

public class Consumer extends Thread
{ 
    private BlockingQueue<MyObject> queue;
    ...
    public void run()
    {
        while (true)
        {
        MyObject o = queue.poll();

        // Work on MyObject 'o'
        ...
        sleep(5*60*1000);
        }
    }
}

当我运行程序时，“top”显示 JAVA 进程始终处于 100%。我猜这是因为无限循环。

这是实现此目的的好方法还是有更节省资源的方法？

Answer 1

而不是

MyObject o = queue.poll();

尝试

MyObject o = queue.take();

后者将阻塞，直到队列中有可用的东西，而前者总是立即返回，无论是否有可用的东西。