c++ - 在使用pthread_create 创建的线程之间读写管道时是否需要关闭fds？

Question

我正在处理一个客户端服务器应用程序。以下是来自客户端的代码。

pipe_input, pipe_output 是共享变量。

        int fds[2];
            if (pipe(fds)) {
                        printf("pipe creation failed");
                    }  else {
                        pipe_input = fds[0];
                        pipe_output = fds[1];
                        reader_thread_created = true;
                        r = pthread_create(&reader_thread_id,0,reader_thread,this);
                        }


 void* reader_thread(void *input)
    {
    unsigned char id;
        int n;
        while (1) {

            n = read(pipe_input , &id, 1);
            if (1 == n) {
                //process
            }if ((n < 0) ) {
                printf("ERROR: read from pipe failed");
                break;
            }
        }
        printf("reader thread stop");
        return 0;
    }

还有一个写入线程，它写入来自服务器的事件更改数据。

void notify_client_on_event_change(char id)
{
    int n;
    n= write(pipe_output, &id, 1);
    printf("message written to pipe done ");
}

我的问题是我是否需要关闭读取器线程中的写入端和写入器线程中的读取端。在析构函数中，我正在等待读取线程退出，但有时它不会从读取线程退出。

Answer 1

[...] do i need to close the write end in reader thread and read end in case of writer thread[?]

因为那些 fds“是共享的”，在一个线程中关闭它们会为所有线程关闭它们。我怀疑那不是你想要的。