如何用pthread_cleanup_push清理线程中的int/数组/结构体变量？

首先明确：你代码里的int num、栈数组array、结构体变量这些栈上分配的局部变量，根本不需要手动清理——线程一旦终止（不管是正常退出还是被pthread_cancel取消），操作系统会自动回收整个线程的栈空间，这些变量占用的内存会被释放，不存在内存泄漏的问题。

你代码里的几个关键错误 #

1. 结构体未定义：struct struct_var;只是声明了类型，没有定义结构体的具体内容，也没有创建变量实例，正确写法应该是先定义结构体类型，再创建变量：

   struct struct_var {
       int val;
       // 其他字段
   };
   struct struct_var s; // 创建结构体变量
   

2. pthread_cleanup_push/pop用法错误：这两个是成对出现的宏，你在push之后立刻用pthread_cleanup_pop(0)，等于直接取消了清理函数的注册，线程被cancel时不会触发任何清理逻辑。正确的用法是把需要保护的代码放在push和pop之间，pop的参数如果是1，会立刻执行清理函数；如果是0，只有线程被cancel或调用pthread_exit时才会执行。

3. 全局变量handler的竞争问题：main线程可能在子线程还没完成handler = pthread_self()赋值时，就调用pthread_cancel(handler)，导致取消失败。直接用pthread_create返回的t来取消线程更可靠。

什么时候需要清理函数？ #

只有当变量/资源满足以下情况时，才需要在pthread_cleanup_push注册的清理函数中处理：

• 变量是堆内存分配的（比如用malloc/calloc动态分配的内存）
• 持有系统资源（比如打开的文件描述符、互斥锁、网络套接字、管道等）

举个例子，如果结构体里包含堆内存，清理逻辑应该是这样：

struct struct_var {
    char* buf;
};

static void cleanup_struct(void* arg) {
    struct struct_var* s = (struct struct_var*)arg;
    if (s->buf) {
        free(s->buf); // 释放堆内存
        s->buf = NULL;
    }
}

static void* thread_func(void* p) {
    struct struct_var s;
    s.buf = malloc(1024); // 堆分配内存

    pthread_cleanup_push(cleanup_struct, &s);

    while (1) {
        // 业务逻辑
        sleep(1);
    }

    pthread_cleanup_pop(1); // 正常退出时也执行清理
    return NULL;
}

修正后的完整代码示例 #

#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <pthread.h>

// 定义结构体类型
struct struct_var {
    int val;
};

// 只有当资源需要手动释放时才需要清理函数，栈变量不需要
static void cleanup_heap_buf(void* arg) {
    char* buf = (char*)arg;
    if (buf) {
        free(buf);
        printf("Cleaned up heap buffer\n");
    }
}

static void* thread_func(void* p) {
    int num = 0;  // 栈int变量，自动回收
    unsigned char array[8] = {0}; // 栈数组，自动回收
    struct struct_var s; // 栈结构体变量，自动回收
    char* heap_buf = malloc(1024); // 堆内存，需要手动清理

    // 注册清理函数，保护堆内存
    pthread_cleanup_push(cleanup_heap_buf, heap_buf);

    while (1) {
        printf("thread: num = %d\n", num++);
        sleep(1);
    }

    // 正常退出时也执行清理（参数1）
    pthread_cleanup_pop(1);
    return NULL;
}

int main(void) {
    int count;
    pthread_t t;
   
    pthread_create(&t, NULL, thread_func, NULL);
    
    for(count = 0; count < 10; count++){
        printf("main: count = %d\n", count);
        if(count == 5){
            printf("main: terminating thread\n");
            pthread_cancel(t); // 直接用pthread_create返回的线程ID
        }
        sleep(1);
    }

    pthread_join(t, NULL); // 等待线程终止，避免僵尸线程
    return 0;
}

补充说明 #

• 线程被pthread_cancel取消时，会在最近的取消点触发终止，并依次执行所有通过pthread_cleanup_push注册的清理函数（按注册的逆序执行）。
• 栈上的所有局部变量都会随着线程栈的销毁而自动释放，不需要额外处理；只有堆内存和系统资源需要手动清理。

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