如何中断阻塞在take（）的BlockingQueue？ [英] How to interrupt a BlockingQueue which is blocking on take()?

问题描述

我有一个类从 BlockingQueue 接受对象，并通过在连续调用 take（）循环。在某些时候，我知道没有更多的对象将被添加到队列。如何中断 take（）方法，使其停止阻塞？

I have a class that takes objects from a BlockingQueue and processes them by calling take() in a continuous loop. At some point I know that no more objects will be added to the queue. How do I interrupt the take() method so that it stops blocking?

：

public class MyObjHandler implements Runnable {

  private final BlockingQueue<MyObj> queue;

  public class MyObjHandler(BlockingQueue queue) {
    this.queue = queue;
  }

  public void run() {
    try {
      while (true) {
        MyObj obj = queue.take();
        // process obj here
        // ...
      }
    } catch (InterruptedException e) {
      Thread.currentThread().interrupt();
    }
  }
}

这个类处理对象：

public void testHandler() {

  BlockingQueue<MyObj> queue = new ArrayBlockingQueue<MyObj>(100);  

  MyObjectHandler  handler = new MyObjectHandler(queue);
  new Thread(handler).start();

  // get objects for handler to process
  for (Iterator<MyObj> i = getMyObjIterator(); i.hasNext(); ) {
    queue.put(i.next());
  }

  // what code should go here to tell the handler
  // to stop waiting for more objects?
}

推荐答案

如果中断线程一个选项，另一个是在队列上放置一个标记或命令对象，这些对象将被MyObjHandler识别并跳出循环。

If interrupting the thread is not an option, another is to place a "marker" or "command" object on the queue that would be recognized as such by MyObjHandler and break out of the loop.

这篇关于如何中断阻塞在take（）的BlockingQueue？的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！