Подача резьбы другим MultiThreading - PullRequest
Новая
       7

Подача резьбы другим MultiThreading

0 голосов
/ 02 мая 2010

Я вижу, что легко открыть канал между двумя процессами, используя fork, но как мы можем передать открытый канал в потоки. Предположим, что нам нужно передать из ПРОГРАММЫ A в ПРОГРАММУ B "может быть более чем на один поток", ПРОГРАММА B отправляет свой вывод в ПРОГРАММУ C

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);
}

1 Ответ

0 голосов
/ 02 мая 2010

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

...