巨大的CPU冲击LinkedBlockingQueue

Question

我有一个名为LinkedBlockingQueue的tasks，但是当我调用tasks.take()并等待任务可用时，CPU的使用率是100%。我使用tasks.take()方法获得了多个线程(每个线程都有自己的tasks变量)。有人知道为什么会这样吗？

tasks变量的缺陷

private LinkedBlockingQueue<ComputerTask> tasks;
// snip
this.tasks = new LinkedBlockingQueue<ComputerTask>(100);

接受任务的代码

ComputerTask task = tasks.take();

提供新任务的代码

this.tasks.offer(task);

我不知道我的Java版本是不是出了问题，因为我还没有在其他计算机上测试过它。

java version "1.6.0_31"
Java(TM) SE Runtime Environment (build 1.6.0_31-b04-413-11M3623)
Java HotSpot(TM) 64-Bit Server VM (build 20.6-b01-413, mixed mode)

Answer 1

我有一个名为LinkedBlockingQueue的任务，但是当我调用tasks.take()并等待任务可用时，CPU的使用率是100%。我使用tasks.take()方法获得了多个线程(每个线程都有自己的任务变量)。

tasks.take();不应该旋转，除非它正在脱列大量的项目。如果队列是空的，它会阻塞，所以我怀疑这不是100%加载的原因。我会确保您在take()周围使用分析器或添加调试语句，以查看它是否被多次调用。

需要记住的一点是，如果队列已满，tasks.offer(task)将立即返回false。我想知道你应该使用tasks.put(task)，它会阻塞而不是旋转。如果您使用offer()来确定要在哪个任务处理程序上运行任务，那么当所有任务处理程序的队列都已满时，您可能是在循环吗？

如果您正在执行自己的任务管理，则可以考虑使用内置的ExecutorService类之一。然后，您可以提交所有任务或使用阻塞队列，ExecutorService将处理池中的每个线程--它的任务：

// start 10 threads handling the tasks
ExecutorService threadPool = Executors.newFixedThreadPool(10);
// now submit tasks to the pools that will be run with the 10 threads
threadPool.submit(task);
...

在上面的例子中，ComputerTask必须实现Runnable。