正确实施进程间通信（IPC）

Question

以下是进程间通信的正确实现吗？

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

它似乎有效，但我想知道是否存在导致挂起的竞争条件。一个限制是两个进程都需要以任何顺序独立启动。

Answer 1

一些压力测试显示没有问题，所以如果有人想重用代码，实施似乎没问题。

正确实施进程间通信（IPC）

Proper implementation of an inter process communication (IPC)

linux

ipc

process

inter-process-communicat