以下是否正确地实现了进程间通信?

#include <stdio.h>
#include <fcntl.h>
#include <sys/poll.h>

int main(int argc, char** argv) {
    if (argc > 1) {
//Sending side
        struct stat buffer;
        if (stat("/tmp/PROCAtoPROCB", &buffer) != 0)
            mkfifo("/tmp/PROCAtoPROCB", (mode_t)0600);

        int fdFIFO = open("/tmp/PROCAtoPROCB", O_WRONLY | O_NONBLOCK);
        if (fdFIFO > 0) {
            write(fdFIFO, (void *)argv[1], sizeof(argv[1]));
            close(fdFIFO);
        }
    } else {
//Receiving side
        int fdFIFO = -1;
        struct stat buffer;
        if (stat("/tmp/PROCAtoPROCB", &buffer) != 0)
            mkfifo("/tmp/PROCAtoPROCB", (mode_t)0600);

        while (1) {
            struct pollfd pollfds[1];
            if (fdFIFO == -1)
                fdFIFO = open("/tmp/PROCAtoPROCB", O_RDONLY | O_NONBLOCK);
            pollfds[0].fd = fdFIFO;
            pollfds[0].events = POLLIN;
            poll(pollfds, 1, -1);
            if (pollfds[0].revents & POLLIN) {
                char buf[1024];
                read(fdFIFO, &buf, 1024);
                close(fdFIFO);
                fdFIFO = -1;
                printf("Other process says %s\n", buf);
            }
            printf("End of loop\n");
        }
    }
    return 0;
}


它似乎正在工作,但我想知道是否可能存在导致挂起的竞赛条件。一个约束是,两个过程都需要以任何顺序独立启动。

最佳答案

一些压力测试表明没有问题,因此如果有人想重用代码,则实现似乎可以。

10-06 02:05