C++怎么使用多进程 C++多进程编程的基本方法

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

int main() {
  pid_t pid = fork();

  if (pid == 0) {
    // 子进程
    std::cout << "子进程 (PID: " << getpid() << ") 正在运行" << std::endl;
    // 执行子进程的任务
    return 0;
  } else if (pid > 0) {
    // 父进程
    std::cout << "父进程 (PID: " << getpid() << ") 创建了子进程 (PID: " << pid << ")" << std::endl;
    wait(nullptr); // 等待子进程结束
    std::cout << "子进程已结束" << std::endl;
  } else {
    // fork 失败
    std::cerr << "fork() 失败" << std::endl;
    return 1;
  }

  return 0;
}

#include <iostream>
#include <sys/ipc.h>
#include <sys/shm.h>
#include <semaphore.h>
#include <fcntl.h> // For O_CREAT and O_EXCL
#include <unistd.h>

const int SHM_SIZE = 1024;
const char* SEM_NAME = "/my_semaphore";

int main() {
  // 1. 获取共享内存
  key_t key = ftok("shmfile", 65); // 创建一个key
  int shmid = shmget(key, SHM_SIZE, 0666 | IPC_CREAT);
  if (shmid == -1) {
    perror("shmget");
    return 1;
  }

  // 2. 映射共享内存到进程地址空间
  char* shm = (char*)shmat(shmid, nullptr, 0);
  if (shm == (char*) -1) {
    perror("shmat");
    return 1;
  }

  // 3. 创建或打开信号量
  sem_t* sem = sem_open(SEM_NAME, O_CREAT | O_EXCL, 0666, 1); // 初始化为1
  if (sem == SEM_FAILED) {
    if (errno == EEXIST) {
      sem = sem_open(SEM_NAME, 0); // 如果信号量已存在，则打开
    } else {
      perror("sem_open");
      shmdt(shm);
      shmctl(shmid, IPC_RMID, nullptr);
      return 1;
    }
  }

  pid_t pid = fork();

  if (pid == 0) {
    // 子进程
    sem_wait(sem); // 获取信号量，进入临界区
    std::cout << "子进程读取到的数据: " << shm << std::endl;
    sem_post(sem); // 释放信号量，退出临界区
    shmdt(shm);
    sem_close(sem);
    return 0;
  } else if (pid > 0) {
    // 父进程
    sem_wait(sem); // 获取信号量，进入临界区
    sprintf(shm, "Hello from parent process!");
    sem_post(sem); // 释放信号量，退出临界区
    wait(nullptr);
    shmdt(shm);
    shmctl(shmid, IPC_RMID, nullptr); // 删除共享内存
    sem_close(sem);
    sem_unlink(SEM_NAME); // 删除信号量
  } else {
    perror("fork");
    shmdt(shm);
    shmctl(shmid, IPC_RMID, nullptr);
    sem_close(sem);
    sem_unlink(SEM_NAME);
    return 1;
  }

  return 0;
}

#include <iostream>
#include <signal.h>
#include <unistd.h>
#include <sys/wait.h>

void signal_handler(int signum) {
  std::cout << "接收到信号: " << signum << std::endl;
  // 处理信号
}

int main() {
  struct sigaction sa;
  sa.sa_handler = signal_handler;
  sigemptyset(&sa.sa_mask);
  sa.sa_flags = 0;
  sigaction(SIGINT, &sa, nullptr); // 注册 SIGINT 信号处理程序

  pid_t pid = fork();

  if (pid == 0) {
    // 子进程
    while (true) {
      std::cout << "子进程正在运行..." << std::endl;
      sleep(1);
    }
    return 0;
  } else if (pid > 0) {
    // 父进程
    std::cout << "父进程正在运行..." << std::endl;
    sleep(5);
    kill(pid, SIGINT); // 向子进程发送 SIGINT 信号
    wait(nullptr);
    std::cout << "子进程已结束" << std::endl;
  } else {
    perror("fork");
    return 1;
  }

  return 0;
}