为什么 write() 终止我的线程？

Question

我用pthread_create()创建了一个线程来执行一个函数，在函数内部有一个write()函数通过套接字描述符发送数据。如果write()函数发送数据失败（因为socket连接丢失），我的线程就终止了。

write() 失败时我可以保留一个线程吗？

这是我的代码：

   void broadcastMsg(char *msg) {
        int i=0;
        while(1) {
            ...
            ...
            // My thread terminated from here
            if(write(client_database.sock_desc[i], msg, strlen(msg)) < 0) {
                client_database.sock_desc[i] = -3;
                i++;
                continue;
            }

            i++;
        }
    }

    /* Start thread from this function */
    void *cliListener(void *argvp) {
        int read_desc;
        char buf[MAX_TRANSFER_BUF];
        int cli_sock_desc_id = atoi(argvp);

        while(1) {
            memset(buf, 0, MAX_TRANSFER_BUF);
            read_desc = read(client_database.sock_desc[cli_sock_desc_id], buf, MAX_TRANSFER_BUF);

            ...
            ...

            broadcastMsg(buf);
        }
    }

    int main(void) {
        ...
        ...
        pthread_t tid_1;
        pthread_create(&tid_1, NULL, cliListener, cli_listener_arg);
        ...
        ...
    }

Answer 1

如果您尝试写入管道或套接字描述符的另一端已关闭（因此没有人会读取它），系统将向您的进程发送 SIGPIPE 信号，默认情况下会杀死进程¹。您可以通过忽略 SIGPIPE 来避免这种命运，通常在 main 函数的早期：

signal(SIGPIPE, SIG_IGN);

一旦你这样做了，写入将不再杀死你的线程或进程；相反，它将返回一个错误 (-1)，并将 errno 设置为 EPIPE。您需要确保您始终检查写入调用的返回值，并在出现错误时执行适当的操作，否则您的程序可能会在后台运行在你认为它已经停止之后......

---

¹_{取决于你如何设置它可能只杀死线程而不是整个过程，但为了一般安全和卫生，它应该杀死整个进程}