(如何)使用此ConcurrentLinkedQueue和sleep()可能"错过信号"？

Question

在我的Java应用程序中,有几个线程将数据放入队列中,另一个线程(只有一个)接受对象并调度它们.

有时,消费线程似乎没有注意到新项目已添加到队列中,因为指示轮询的日志消息不再出现.来自生成线程的日志消息表明这些项确实到达.谷歌搜索一些人告诉我,这似乎被称为"错过信号".由于我既不wait使用也不使用锁,我不确定这是否适用于我.

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

这是消费者线程的主循环,生产者线程做的事情就像从套接字读取一样,它们唯一常见的是它们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);
            }
        });
    }
}