停止Java中的循环线程

Question

我正在使用从队列中连续读取的线程。

就像是：

public void run() {
    Object obj;
    while(true) {
        synchronized(objectsQueue) {
            if(objectesQueue.isEmpty()) {
                try {
                    objectesQueue.wait();
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }

                obj = objectesQueue.poll();
            }
        }

        // Do something with the Object obj
    }
}

停止此线程的最佳方法是什么？

我看到两个选择：

1-由于Thread.stop()已弃用，因此我可以实现stopThisThread()使用原子检查条件变量的方法。

2-将死亡事件对象或类似的对象发送到队列。当线程获取死亡事件时，它退出。

我更喜欢第一种方法，但是，我不知道何时调用该stopThisThread()方法，因为可能有某种方法进入队列，并且停止信号可能首先到达（这是不希望的）。

有什么建议？

Answer 1

该DeathEvent（或因为它是常说，“毒丸计划”）的做法效果很好，如果你要在关闭之前完成队列上的所有工作。问题是这可能需要很长时间。

如果您想尽快停止，建议您这样做

BlockingQueue<O> queue = ...

...

public void run() {
   try {
       // The following test is necessary to get fast interrupts.  If
       // it is replaced with 'true', the queue will be drained before
       // the interrupt is noticed.  (Thanks Tim)
       while (!Thread.interrupted()) {
           O obj = queue.take();
           doSomething(obj);
       }
   } catch (InterruptedException ex) {
       // We are done.
   }
}

要停止t使用该run方法实例化的线程，只需调用t.interrupt();。

如果将上面的代码与其他答案进行比较，您会注意到如何使用BlockingQueue和Thread.interrupt()简化html" target="_blank">解决方案。

我还要声称，stop不需要多余的标志，并且从总体上看可能有害。行为良好的工作线程应尊重中断。意外中断只是意味着该工作程序正在原始程序员无法预期的环境中运行。最好的事情是，如果工人去做被告知要做的事情，即应该停止……这是否符合原始程序员的构想。