프로세스 간 통신(IPC)

#include <stdio.h>
#include <unistd.h>
#include <sys/wait.h>

int main(void) {
    int fd[2];
    pipe(fd);                          /* fd[0]=읽기 끝, fd[1]=쓰기 끝 */

    if (fork() == 0) {                /* 자식: 읽는 쪽 */
        close(fd[1]);
        char buf[64];
        ssize_t n = read(fd[0], buf, sizeof(buf) - 1);
        if (n < 0) return 1;
        buf[n] = 0;
        printf("child got: %s\n", buf);
        return 0;
    }
    close(fd[0]);                       /* 부모: 쓰는 쪽 */
    write(fd[1], "hello", 5);
    close(fd[1]);
    wait(NULL);
}

/* 쓰는 프로세스 */
int fd = shm_open("/demo", O_CREAT | O_RDWR, 0600);
ftruncate(fd, 4096);
char *p = mmap(NULL, 4096, PROT_READ | PROT_WRITE, MAP_SHARED, fd, 0);
strcpy(p, "hello");                  /* 메모리에 쓰기만 하면 됨 */

/* 읽는 프로세스 (같은 이름으로 열어서 같은 영역을 매핑) */
int fd2 = shm_open("/demo", O_RDWR, 0);
char *q = mmap(NULL, 4096, PROT_READ, MAP_SHARED, fd2, 0);
printf("%s\n", q);

shm_unlink("/demo");                 /* 더 쓰지 않으면 이름 제거 */

# 셸: 이름 있는 파이프 (관련 없는 두 프로세스가 이름으로 연결)
mkfifo /tmp/demo.fifo
cat /tmp/demo.fifo &                 # 읽는 쪽: 데이터가 올 때까지 대기
echo hello > /tmp/demo.fifo          # 쓰는 쪽

# Python: 프로세스 사이에 파이프 / 공유 메모리
from multiprocessing import Process, Pipe, shared_memory

def child(conn):
    conn.send("hi")

if __name__ == "__main__":
    parent, c = Pipe()
    p = Process(target=child, args=(c,)); p.start()
    print(parent.recv()); p.join()

    shm = shared_memory.SharedMemory(create=True, size=16)
    shm.buf[:2] = b"ok"
    shm.close(); shm.unlink()