4

因此，我正在开发一个实时处理视频的程序，并且在线程“阻塞”彼此时遇到了一些麻烦。

我的系统几乎是这样设置的：

         DataSourceThread
             /      \
            /        \
           /          \
     Receiver       Receiver
         /              \
        /                \ 
       /                  \
 Processor1            Processor2

（所有这些类都在扩展 QThread。）

因此 DataSourceThread 从视频流中获取帧并向接收器发出包含该帧的信号。连接类型：Qt::DirectConnection

接收器基本上接收 DataSourceThread 发出的帧，如果处理器完成对前一帧的处理，它将向处理器发出包含该帧的信号。连接类型：Qt::QueuedConnection。 如果处理器没有完成对前一帧的处理，它只会返回而不发出信号（跳帧）。

为了测试这是否有效，我所做的只是让 Processor1 在收到帧时打印一条消息，而 Processor2 执行QThread::sleep(3); 并打印出一条消息。

（在将帧传递给处理器之前，接收器还将对帧进行深度复制。）

预期结果：

Processor1 应该不断地打印消息。Processor2 应该每 3 秒打印一次消息。

问题：

两个处理器同时打印它们的消息（每 3 秒）。Processor1 等到 Processor2 完成后再打印它的消息。所以输出几乎是这样的：

"Message from processor1"
"Message from processor2"
"Message from processor1"
"Message from processor2"
"Message from processor1"
"Message from processor2"

等等。

我在这里没有想法，所以任何帮助将不胜感激！

编辑： 这是一些代码：

主.cpp：

int main(int argc, char *argv[])
{
    QApplication app(argc, argv);

    DataSourceThread dataSourceThread;
    dataSourceThread.start();

    GUIThread *guiProcessor = new GUIThread();
    FrameReceiver *guiReceiver = new FrameReceiver(guiProcessor, 0);

    QObject::connect(
        &dataSourceThread, SIGNAL(frameReceived(Frame*)),
        guiReceiver, SLOT(receive(Frame*)),
        Qt::DirectConnection
    );

    DetectorThread *detectorProcessor = new DetectorThread();
    FrameReceiver *detectorReceiver = new FrameReceiver(detectorProcessor, 0);

    QObject::connect(
        &dataSourceThread, SIGNAL(frameReceived(Frame*)),
        detectorReceiver, SLOT(receive(Frame*)),
        Qt::DirectConnection
    );

    return app.exec();
}

从 DataSourceThread.cpp：

void DataSourceThread::run()
{
    ... stuff ...

    while (true) {
        image = cvQueryFrame(capture);

        if (!image) { 
            qDebug() << QString("Could not capture frame"); 
            continue;
        }

        cvReleaseImage(&temp_image);
        temp_image = cvCreateImage(cvSize(640, 480), image->depth, 3);

        cvResize(image, temp_image, 1);

        frame->lock();
        frame->setImage(temp_image);
        frame->unlock();

        emit frameReceived(frame);

        msleep(1); 
    }
}

帧接收器.cpp：

FrameReceiver::FrameReceiver(FrameProcessor* processor, QObject *parent) : QThread(parent) {
    m_ready = true;

    m_processor = processor;
    m_processor->start();

    QObject::connect(
        (QObject*)this, SIGNAL(frameReceived(Frame*)),
        m_processor, SLOT(receive(Frame*)), 
        Qt::QueuedConnection
    );

    QObject::connect(
        m_processor, SIGNAL(ready()),
        (QObject*)this, SLOT(processCompleted()),
        Qt::DirectConnection
    ); }

void FrameReceiver::processCompleted() {
    m_ready = true; }

void FrameReceiver::receive(Frame *frame) {
    if (m_ready == true) {
        m_ready = false;
        frame->lock();
        Frame *f = new Frame(*frame);
        frame->unlock();
        emit frameReceived(f);
    } else {
        // SKIPPED THIS FRAME
    }
}

GUIThread.cpp：（处理器 1）

GUIThread::GUIThread(QObject *parent) : FrameProcessor(parent)
{
    m_frame = new Frame();
}

void GUIThread::setFrame(Frame *frame)
{ 
    qDebug() << QString("Guithread received frame");
}

帧处理器.cpp

// (The processors extend this class)
void FrameProcessor::receive(Frame *frame)
 {
     setFrame(frame);
     delete frame;
     emit ready();
 }

DetectorThread (Processor2)的作用与 guithread 相同，但在 setFrame 中休眠 3 秒。

4

1 回答 1

3

我认为部分问题是您所有的 QObjects 都归主应用程序线程所有。这意味着它们都共享一个事件循环来传递异步信号，从而有效地序列化整个处理链。

我认为设置它的正确方法是：

GUIProcessor *guiProcessor = new GUIProcessor();
QThread guiProcessorThread;
guiProcessor.moveToThread(&guiProcessorThread);

FrameReceiver *guiReceiver = new FrameReceiver(guiProcessor, 0);
QThread guiReceiverThread;
guiReceiver.moveToThread(&guiReceiverThread);

guiProcessorThread.start();
guiReceiverThread.start();

如果你这样做，我建议不要DirectConnection在线程之间使用，而是BlockingQueuedConnection如果你想确保在捕获下一帧之前处理当前帧。

看到这个： http: //labs.qt.nokia.com/2010/06/17/youre-doing-it-wrong/

这： http: //labs.qt.nokia.com/2006/12/04/threading-without-the-headache/

希望这可以帮助！

编辑：要清楚，根据我的建议，您的类将继承 QObject 而不是 QThread。

于 2011-01-18T22:41:32.727 回答