c - 如何在管道的文件描述符上的线程 block 中进行 read() ？

Question

我正在尝试如何在C语言中的线程和主函数之间进行通信以下代码中有一个我不理解的行为:

#include <pthread.h>

#include <string.h>
#include <stdio.h>
#include <unistd.h>

void* output(void* pipe1);

int main(int argc, const char *argv[])
{
    pthread_t   tid0;
    int         pipe1[2];
    char        buffer[200];

// Creating the pipe
    pipe(pipe1);
// Creating the thread and passing the pipe as argument
    pthread_create(&tid0, NULL, output, &pipe1);
// Input from user
    scanf("%s", buffer);
// Writing to the pipe
    write(pipe1[1], buffer, strlen(buffer));
    return 0;
}

void* output(void* pipe1) {
     char buffer[200];

// Reading the pipe and print the buffer
     read(((int*)pipe1)[0], buffer, strlen(buffer));
     printf("thread say: %s\n", buffer);
     pthread_exit(NULL);
}

为什么读取函数不会在管道的文件描述符上阻塞？

也许我应该关闭管道的末端，但由于它们共享相同的内存空间，因此当我调用 read 或 write 时会返回错误“错误文件描述符”。

如果管道确实是一个糟糕的解决方案，也许你可以指导我使用其他方法(如果有一个例子，那就太棒了!:))

非常感谢!

编辑:解决方案

非常感谢您的回答，这里的代码具有预期的行为

#include <pthread.h>

#include <string.h>
#include <stdio.h>
#include <unistd.h>
#include <stdlib.h>

void* output(void* pipe1);

int main(int argc, const char *argv[])
{
    pthread_t   tid0;
    int         pipe1[2];
    char        buffer[200];

// Creating the pipe
    pipe(pipe1);
// Creating the thread and passing the pipe as argument
    pthread_create(&tid0, NULL, output, &pipe1);

// Input from user
    scanf("%s", buffer);
// Writing to the pipe
    if (write(pipe1[1], buffer, strlen(buffer)) < 0) {
        perror("write");
        exit(1);
    }
    // join so the main "wait" for the thread
    pthread_join(tid0, NULL);
    return 0;
}


void* output(void* pipe1) {
    char        buffer[200];
    int         nread;

// Reading the pipe and print the buffer
    nread = read(((int*)pipe1)[0], buffer, sizeof buffer - 1);
    if (nread < 0) {
        fprintf(stderr, "ERROR\n");
        perror("read");
        exit(1);
    }
    buffer[nread] = '\0';
    fprintf(stderr, "thread say: %s\n", buffer);
    pthread_exit(NULL);
}

Answer 1

char buffer[200];
read(((int*)pipe1)[0], buffer, strlen(buffer));

您正在对未初始化的缓冲区调用strlen。这会导致你的程序崩溃。相反，您很幸运，它所做的只是告诉 read 读取零字节，因此 read 返回而不执行任何操作。

你真正想要的是

ssize_t nread = read(((int *)pipe1)[0], buffer, sizeof buffer - 1);
if (nread < 0) {
    perror("read");
    return 0;
}
buffer[nread] = '\0';

read 想要知道的是您要给它读入多少空间，而不是该字符串中可能存在或尚未存在的任何字符串的长度空间。这是 sizeof buffer 减一，这样我们总是有空间来添加字符串终止符。

写入时使用strlen是正确的，因为你只想写入实际的字符串，而不是任何可能超出字符串末尾的垃圾；但是 write 不会将字符串终止符写入管道，因此 read 不会读取，因此您必须通过以下方式添加它:手。当然，还要始终检查错误。

此外，请记住线程同时运行。即使修复了此错误后，当读取器线程调用 read 时，write 可能已经发生，如果还没有发生，它可能很快就会发生。如果您想观察读取线程在读取时实际阻塞，则需要在调用写入之前延迟。