套接字和多线程

Question

我有一个有趣的（对我来说）问题...有两个线程，一个用于从 std 输入捕获数据并通过套接字将其发送到服务器，另一个线程从阻塞套接字接收数据。那么，当服务器没有回复时，recv() 调用就会无限期地等待，对吧？但它不是仅阻塞其调用线程，而是阻塞整个进程！为什么会出现这种情况呢？

boost::mutex     nvtMutex;
boost::mutex    strMutex;
boost::mutex    quitMutex;
bool        quit = false;

void *processServerOutput(void *arg)
{
    NVT *nvt = (NVT*)arg;
    while(1)
    {
        // Lock the quitMutex before trying to access to quit variable
        quitMutex.lock();
        if(quit)
        {
            quitMutex.unlock();
            pthread_exit(NULL);
        }
        else
            quitMutex.unlock();

        // Receive output from server
        nvtMutex.lock();
        nvt->receive();
        cout << Util::Instance()->iconv("koi8-r", "utf-8", nvt->getOutBuffer());
        nvtMutex.unlock();

        // Delay
        sleep(1);
    }
}

void *processUserInput(void *arg)
{
    NVT *nvt = (NVT*)arg;

    while(1)
    {
        // Get user's input
        //cin.getline(str, 1023);

        sleep(3);
        strcpy(str, "hello");

        // If we type 'quit', exit from thread
        if(strcmp(str, "quit") == 0)
        {
            // Lock quit variable before trying to modify it
            quitMutex.lock();
            quit = true;
            quitMutex.unlock();

            // Exit from thread
            pthread_exit(NULL);
        }

        // Send the input to server
        nvtMutex.lock();
        nvt->writeUserCommand(Util::Instance()->iconv("utf-8", "koi8-r", str));
        nvt->send();
        nvtMutex.unlock();
    }
}

Answer 1

您将 nvtMutex 保存在对 NVT::recv 的调用中。由于两个线程都需要锁定互斥体才能完成迭代，因此在 NVT::recv 返回之前，另一个线程无法继续进行。

如果不知道此 NVT 类的详细信息，就不可能知道在调用 NVT::recv 之前是否可以安全地解锁互斥锁，或者该类是否未提供正确的线程您需要的安全。

Answer 2

如果您的代码实现正确，recv 只会阻塞调用它的线程。

如果您的情况并非如此，请显示演示该问题的最小代码示例。