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

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

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

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

这是消费者线程的主循环，生产者线程执行诸如从套接字读取之类的操作，它们唯一的共同点是它们使用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);
                    }
                }
            }
        }

    // ...
}

也许您最好使用结合了线程池和队列的 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);
            }
        });
    }
}