Подача нитей другой MultiThreading

Question

Я вижу, что легко открыть трубку между двумя процессами, используя вилку, но как мы можем передавать открытую трубу в потоки. Предположим, нам нужно пройти из ПРОГРАММЕ А в ПРОГРАММЕ B «может более чем одной нити», ПРОГРАММА B отправить свой вывод ПРОГРАММА С

EDIT: возвращусь после изменения кода, чтобы стать более легким для чтение.

#include <stdio.h> 
#include <stdlib.h> 
#include <pthread.h> 
#include <fcntl.h> 

void *thread1(void *arg) { 

    int status, fd[2]; 
    pid_t pid; 

    pipe(fd); 
    pid = fork(); 

    if (pid == 0) { 
     int fd2 = *((int *) (arg)); 
     dup2(STDIN_FILENO, fd2); 

     close(fd[0]); 
     dup2(fd[1], STDOUT_FILENO); 
     close(fd[1]); 

     execvp("PROGRAM B", NULL); 
     exit(1); 
    } else { 
     close(fd[1]); 
     dup2(fd[0], STDIN_FILENO); 
     close(fd[0]); 

     execl("PROGRAM C", NULL); 
     wait(&status); 

     return NULL; 
    } 
} 

int main(void) { 


    FILE *fpipe; 
    char *command = "PROGRAM A"; 
    char buffer[1024]; 

    if (!(fpipe = (FILE*) popen(command, "r"))) { 
     perror("Problems with pipe"); 
     exit(1); 
    } 

    char* outfile = "out.dat"; 
    //FILE* f = fopen (outfile, "wb"); 
    //int fd = fileno(f); 

    int fd[2]; 
    fd[0] = open(outfile, O_WRONLY); 

    pthread_t thid; 
    if (pthread_create(&thid, NULL, thread1, fd) != 0) { 
     perror("pthread_create() error"); 
     exit(1); 
    } 

    int len; 
    while (read(fpipe, buffer, sizeof (buffer)) != 0) { 
     len = strlen(buffer); 
     write(fd[0], buffer, len); 
    } 

    pclose(fpipe); 

    return (0); 
} 

Answer 1

Для обмена сообщениями между процессами очереди POSIX, скорее всего, удовлетворят ваши потребности лучше, чем трубы. Выезд man mq_overview (или online).