（如何）我可能会“错过信号”吗？使用这个 ConcurrentLinkedQueue 和 sleep()？

Question

在我的 Java 应用程序中，多个线程将数据放入队列中，另一个线程（只有一个）从中获取对象并分派它们。

有时，使用线程似乎没有注意到新项目已添加到队列中，因为指示轮询的日志消息不再出现。来自生产线程的日志消息表明这些项目确实到达。谷歌搜索告诉我，这似乎被称为“丢失信号”。由于我既不等待也不使用锁，因此我不确定这是否适用于我。

真正让我困惑的是，当我中断消费者线程时，它会处理队列中的所有项目，然后再次保持沉默，而不会退出。

这是消费者线程的主循环，生产者线程执行诸如从套接字读取之类的操作，它们唯一的共同点是它们在消费者轮询的队列上使用 add() 。

public class FieldFrontService
{
    // ...

    private ConcurrentLinkedQueue<Transmission> _qRec;

    // ...

    private Runnable _createReceptionist()
    {
        return new Runnable() {
            @Override
            public void run()
            {
                while (!Thread.currentThread().isInterrupted()) {
                    Transmission tx = FieldFrontService.this._qRec.poll();
                    if (null == tx) {
                        try {
                            Thread.sleep(250);
                        } catch (InterruptedException e) {
                            break;
                        }
                    } else {
                        FieldFrontService.this._receiveTransmission(tx);
                    }
                }
            }
        }

    // ...
}

Answer 1

也许您最好使用结合了线程池和队列的 ExecutorService。它也有效。 ;)

public class FieldFrontService {
    private final ExecutorService executor = Executors.newSingleThreadExecutor();

    void receiveTransmission(final Transmission tx) {
        executor.execute(new Runnable() {
            public void run() {
                FieldFrontService.this._receiveTransmission(tx);
            }
        });
    }
}

Answer 2

我认为你的 InterruptedException 正在你的调用堆栈中的某个地方被吃掉。

这种模式是我所关心的：

try {                             
    Thread.sleep(250);
} catch (InterruptedException e) {
    break;
} 

如果您在代码中使用类似的模式，则线程中断状态会丢失。例如，如果在调用堆栈中使用了 Thread.interrupted()，则将 重置线程的中断状态。因此，您的 while 循环将永远不会退出：状态被重置为 false。

这两行是需要关注的地方：

Transmission tx = FieldFrontService.this._qRec.poll();
// ....
FieldFrontService.this._receiveTransmission(tx); 

如果其中任何一个调用调用了 Thread.currentThread().interrupted()，您将丢失 isInterrupted 布尔值。我会检查这两种方法的实现，以防异常/状态被消耗。

我对 InterruptedExceptions 的处理是不同的。我更喜欢重新抛出中断：

try {                             
    Thread.sleep(250);
} catch (InterruptedException e) {
    Thread.currentThread().interrupt();
} 

这样，我可以确保我的中断不可能丢失。基本上，我想说的是，不，说真的，停止线程停止！

Answer 3

难道不是因为break语句退出了while循环，导致线程停止了？如果删除break语句会发生什么？或者这就是你所期望的？

我建议线程看不到新项目，因为线程已经由于您没有预料到的异常而停止。