c++ - 添加用于监听网络的新线程时应用程序卡住

标签 c++ c multithreading qt zeromq

我通过函数 Start_zeroMQResponderThread 向使用 Qt 开发的应用程序添加了一个新线程:

// this function adds the new thread
void MainWindow::Start_zeroMQResponderThread()
{

    moveToThread(&zeroMQResponderthread);
    QObject::connect(&zeroMQResponderthread, SIGNAL(started()), this, SLOT(Run_zeroMQResponderThread())); //cant have parameter sorry, when using connect
    zeroMQResponderthread.start();
}

我在 MainWindow 的构造函数中调用了这个函数,以确保在应用程序启动时创建线程:

MainWindow::MainWindow(QWidget *parent) :
    QMainWindow(parent),
    ui(new Ui::MainWindow)
{
....

    // This is the sender which do not need to be run in a separate thread
    context = zmq_ctx_new();
    requester = zmq_socket(context, ZMQ_PAIR);
    rc = zmq_connect(requester, "tcp://10.131.7.97:5555"); 
...
    //  This is the starting of the thread that will listens to the network to 
    //  capture received messages using ZeroMQ
    Start_zeroMQResponderThread();
}

最后,这是函数 Run_zeroMQResponderThread():它在单独的线程中运行。它使用 ZeroMQ 启动无限循环来检测发送的消息,并使用 Windows Text To Speech API (SAPI) 将它们转换为语音消息:

void MainWindow::Run_zeroMQResponderThread() {

    ISpVoice * pVoice = NULL;
    if (!FAILED(::CoInitialize(NULL)))
    {
        HRESULT hr = CoCreateInstance(CLSID_SpVoice, NULL, CLSCTX_ALL, IID_ISpVoice, (void **)&pVoice);
    }


    void *context = zmq_ctx_new();
    void *responder = zmq_socket(context, ZMQ_PAIR);
    int rc = zmq_bind(responder, "tcp://*:5555");


    printf("Receiver: Started\n");

    char buffer[128];
    wchar_t wtext[128];
    while (true)
    {
        int num = zmq_recv(responder, buffer, 128, 0);

        if (num > 0)
        {
            buffer[num] = '\0';
            printf("Receiver: Received (%s)\n", buffer);



            mbstowcs(wtext, buffer, strlen(buffer) + 1);//Plus null
            LPWSTR ptr = wtext;
            HRESULT hr;
            if (pVoice)
                hr = pVoice->Speak(ptr, SPF_DEFAULT, NULL);

            if (!SUCCEEDED(hr))
                std::cout << "speak error" << hr << std::endl;
        }
    }

    pVoice->Release();
    pVoice = NULL;
    ::CoUninitialize();

    zmq_close(responder);
    zmq_ctx_destroy(context);


}

在添加这个功能之前,应用程序运行良好。但在添加之后,它在应用程序开始时卡住,甚至没有显示应用程序的主 UI。

可能是什么问题?

最佳答案

QWidget 移动到除主线程或空线程以外的任何线程,这从来都不是可行的。 期间

无论如何,您应该从 UI 中分离出代码的 Controller 方面。 Controller 将驻留在一个或多个 QObject 中。您所要做的就是将那些 移动到工作线程,然后就可以了。

关于c++ - 添加用于监听网络的新线程时应用程序卡住,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/38978752/

相关文章:

c++ - 在 Linux 上为 clang 构建 libc++ 的认可方法是什么?

c++ - Visual Studio 2013 中没有使用直接初始化语法的智能感知

c - mmap for write under MacOSX 10.8.2 with XCode 4.6 will make program crash

c - 如何从确定的位置检查一组位是否为 0?

c - 两个动态库的传递依赖中的符号冲突

android - 如何让用户取消 Android 中的进度通知?

java - 跟踪大型应用程序源代码中的线程初始化

c++ - 什么是开始()==结束()?

java - 在多线程程序中处理更新 hibernate

c++ - 64 位整数方程的意外结果