Linux 带线程的套接字文件描述符

Question

考虑以下情况：一个线程（我们称之为 A）初始化，使用 listen() 设置套接字状态，然后等待 accept()。连接到达套接字，accept() returns 有效的 fd。创建新线程 (B)（使用 std::thread），并将获取的 fd 传递给可调用对象在线程 B 中运行。读取（使用 read()）fd 失败并且 errno 设置为 9 EBADFD。线程 A 在 B 上调用 join()。当未生成 B 并且使用 fd（仍然通过相同的可调用对象）时，读取完成而不会失败。为什么？下面是一些代码来说明这种情况。

BaseFun::BaseFun(char* bufferAdr, int socket):
    socket_fd(socket)
    buffer(bufferAdr)
{}

BaseFun::~BaseFun()
{
    close(socket_fd);
}

char* BaseFun::buffer_read()
{
    if(read(socket_fd, buffer, BUFF_SIZE-1) < 0) {
        std::cout<<"ERROR while READ\n"<<"ERRNO: "<<errno<<"\n"<<"FD: "<<socket_fd<<"\n";
    }
    return buffer;
}

DisplayMsgFun::DisplayMsgFun(char* buffer, int socket) :
    BaseFun(buffer, socket)
{}

void DisplayMsgFunFun::operator()()
{
    std::cout<<"Message:\n\t"<<buffer_read()<<"\nEND\n";
}

上面调用的代码段：

void Server::server_run()
{
    sockaddr_in client_addr;
    socklen_t c_len = sizeof(client_addr);

    client_fd = accept(sock_fd, (sockaddr*)&client_addr, &c_len);
    DisplayMsgFun dm(server_buffers->front().data(), client_fd);
    std::thread job(dm);
    job.join();
}

和main()

int main()
{
    Server srv(PORT);
    if (srv.server_create()) {
        std::cout << "Server bind!\n";
        srv.server_run();
    }
    else {
        std::cout << "Bind fail! ERRNO: "<<errno<<"\n";
        return -1;
    }
    return 0;
}

Answer 1

您似乎将 DisplayMsgFun 对象的 copy 传递给 std::thread 构造函数，这意味着原始副本被销毁，自动调用::close 根据你的析构函数。

Linux 带线程的套接字文件描述符

Linux Socket file descriptor with threads

c++

sockets

linux

multithreading

stdthread