2

我正在尝试制作多客户端服务器。我有这个线程：

void client_thread(int new_socket)
{
    int size;
    char inbuffer[BUF];

    do
    {
        cout << "Waiting for messages: " << endl;
        size = recv(new_socket, inbuffer, BUF, 0);
    } while (true);
}

这个主要程序：

int main()
{
    while (true)
    {
        //waiting for clients
        cout << "Waiting for connections..." << endl;
        new_socket = accept ( create_socket, (struct sockaddr *) &cliaddress, &addrlen );

        //new client connected
        if (new_socket > 0)
        {
            //start thread
            thread(client_thread, new_socket).join();
        }
    }
    return 0;
}

当第一个客户端连接时，线程启动并且服务器正在等待来自他的消息。但是服务器不再等待新客户端。我不知道为什么。是因为do-while线程函数内部的无限循环吗？如果线程包含无限循环，它们会阻塞您的整个程序，那么线程的意义何在？

4

2 回答 2

6

主程序阻塞，因为它等待线程完成：join().

如果您不想阻止，请不要join()使用您的 client_thread。

此异常可能来自您的匿名线程对象的破坏。当你离开作用域时if()，这个作用域内的所有对象都被销毁。从http://en.cppreference.com/w/cpp/thread/thread/~thread你可以看到，析构函数调用terminate(). 为避免它，您可以调用detach(). 所以代替thread(client_thread, new_socket).join();，你必须说thread(client_thread, new_socket).detach();。

于 2012-11-06T22:59:19.163 回答
2

您应该创建一个线程并保留对它的引用，直到您加入它。在您的代码中，线程对象在创建后立即被释放，因此如果不立即调用 join 则会出现错误。

为了正确实现这一点，最好的方法是在堆上分配对象，使用运算符new并将指针存储在某个列表中。当线程完成时，它可能会从列表中删除自己（不要忘记“互斥”它），或者您可以让另一个专用线程这样做：也许您可以简单地让您的主线程在退出之前加入所有其他线程。

于 2012-11-06T23:20:51.710 回答