如何让信号处理程序销毁用IPC_PRIVATE创建的IPC资源

因为不能用全局变量，又要在SIGTERM触发时销毁IPC_PRIVATE类型的信号量和消息队列，这里有几个可行的实现方案：

方法1：利用线程本地存储（TLS）传递IPC资源信息 #

通过线程本地存储存储IPC ID集合，信号处理函数可以直接读取当前线程的TLS数据，不需要依赖全局变量。

示例代码：

#include <signal.h>
#include <sys/ipc.h>
#include <sys/sem.h>
#include <sys/msg.h>
#include <pthread.h>
#include <stdlib.h>
#include <unistd.h>

// 线程本地存储键，用于关联IPC资源结构体
static pthread_key_t ipc_res_key;

// 存储IPC资源ID的结构体
typedef struct {
    int sem_id;
    int msg_id;
} IpcResources;

// SIGTERM处理函数
void sigterm_handler(int signum, siginfo_t *info, void *context) {
    IpcResources *res = pthread_getspecific(ipc_res_key);
    if (res) {
        // 销毁信号量
        semctl(res->sem_id, 0, IPC_RMID);
        // 销毁消息队列
        msgctl(res->msg_id, IPC_RMID, NULL);
        free(res);
    }
    _exit(EXIT_SUCCESS);
}

int main() {
    // 初始化线程本地存储键，指定资源释放函数
    pthread_key_create(&ipc_res_key, free);

    // 创建IPC_PRIVATE资源
    int sem_id = semget(IPC_PRIVATE, 1, 0666 | IPC_CREAT);
    int msg_id = msgget(IPC_PRIVATE, 0666 | IPC_CREAT);

    // 封装IPC ID到结构体并存储到TLS
    IpcResources *res = malloc(sizeof(IpcResources));
    res->sem_id = sem_id;
    res->msg_id = msg_id;
    pthread_setspecific(ipc_res_key, res);

    // 配置sigaction，使用SA_SIGINFO标志启用带参数的处理函数
    struct sigaction sa;
    sa.sa_sigaction = sigterm_handler;
    sigemptyset(&sa.sa_mask);
    sa.sa_flags = SA_SIGINFO | SA_RESTART;
    sigaction(SIGTERM, &sa, NULL);

    // 主程序逻辑示例
    pause();
    return 0;
}

方法2：用管道触发主进程执行清理 #

信号处理函数仅负责向管道写入一个触发信号，主进程通过监听管道事件，执行IPC资源销毁操作。这种方式避免了在信号处理函数中直接操作IPC，符合异步信号安全规范。

示例代码：

#include <signal.h>
#include <sys/ipc.h>
#include <sys/sem.h>
#include <sys/msg.h>
#include <unistd.h>
#include <stdlib.h>

int pipe_fd[2];

// SIGTERM处理函数：仅向管道写入数据
void sigterm_handler(int signum) {
    char trigger = '1';
    // write是异步信号安全函数
    write(pipe_fd[1], &trigger, 1);
}

int main() {
    // 创建管道
    pipe(pipe_fd);

    // 创建IPC_PRIVATE资源
    int sem_id = semget(IPC_PRIVATE, 1, 0666 | IPC_CREAT);
    int msg_id = msgget(IPC_PRIVATE, 0666 | IPC_CREAT);

    // 配置sigaction
    struct sigaction sa;
    sa.sa_handler = sigterm_handler;
    sigemptyset(&sa.sa_mask);
    sa.sa_flags = SA_RESTART;
    sigaction(SIGTERM, &sa, NULL);

    // 主进程监听管道，收到触发信号后清理IPC
    char buf;
    if (read(pipe_fd[0], &buf, 1) > 0) {
        semctl(sem_id, 0, IPC_RMID);
        msgctl(msg_id, IPC_RMID, NULL);
    }

    exit(EXIT_SUCCESS);
}

方法3：用setjmp/longjmp跳回主进程清理 #

通过setjmp保存主进程上下文，信号处理函数中用longjmp跳回主流程，由主进程执行销毁操作，避免在信号处理函数中处理复杂逻辑。

示例代码：

#include <signal.h>
#include <sys/ipc.h>
#include <sys/sem.h>
#include <sys/msg.h>
#include <setjmp.h>
#include <unistd.h>

jmp_buf exit_jmp;

// SIGTERM处理函数：跳转回主进程清理点
void sigterm_handler(int signum) {
    longjmp(exit_jmp, 1);
}

int main() {
    // 创建IPC_PRIVATE资源，用volatile修饰避免编译器优化丢失值
    volatile int sem_id = semget(IPC_PRIVATE, 1, 0666 | IPC_CREAT);
    volatile int msg_id = msgget(IPC_PRIVATE, 0666 | IPC_CREAT);

    // 配置sigaction
    struct sigaction sa;
    sa.sa_handler = sigterm_handler;
    sigemptyset(&sa.sa_mask);
    sa.sa_flags = SA_RESTART;
    sigaction(SIGTERM, &sa, NULL);

    // 保存上下文，setjmp返回0时执行主逻辑，非0时执行清理
    if (setjmp(exit_jmp) == 0) {
        // 主程序逻辑示例
        pause();
    } else {
        // 销毁IPC资源
        semctl(sem_id, 0, IPC_RMID);
        msgctl(msg_id, IPC_RMID, NULL);
    }

    return 0;
}

方案选型建议 #

• 方法1适合单线程场景，TLS保证了数据的线程隔离性，不会污染全局空间。
• 方法2是最安全的方案，信号处理函数仅调用异步安全函数，符合POSIX规范，适合多线程或复杂主逻辑场景。
• 方法3实现简单，但要注意volatile修饰变量，避免编译器优化导致IPC ID丢失。

内容的提问来源于stack exchange，提问作者RaSeille