相关疑难解决方法(0)

在我的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);
                    }
                }
            }
        }

    // ...
}

如果page.waitForSelector()失败，则抛出错误。由于这是在async函数内部运行的，因此if直接进入代码的catch部分。

如果page.waitForSelector()失败，是否有可能在下面的一行执行代码？

像这样（伪代码）：

if ( (await page.waitForSelector('.test') == null) { //do X}

从API：

如果选择器在等待的毫秒数后没有出现，则该函数将抛出。

我如何在同一代码块中管理该抛出，好像功能会成功执行？