导航：首页 > 服务器 >

unix 线程回调函数使用-pthread_cleanup_push && pthread_cleanup_pop

发表于：2025-01-23 作者：千家信息网编辑

千家信息网最后更新 2025年01月23日，#if 0线程结束时清理函数pthread_cleanup_push()，应该在线程开始的时候尽快执行初始化pthread_cleanup_pop()，当遇到以下三种各件会自动调用该函数，不需要PC执

千家信息网最后更新 2025年01月23日unix 线程回调函数使用-pthread_cleanup_push && pthread_cleanup_pop

#if 0
线程结束时清理函数
pthread_cleanup_push()，应该在线程开始的时候尽快执行初始化
pthread_cleanup_pop()，当遇到以下三种各件会自动调用该函数，不需要PC执行到此函数
1.调用pthread_exit()
2.响应取消请求例如pthread_cancel()
3.当pthread_cleanup_pop(arg)参数arg为非0时会线程退出时自动执行
如果没有以上三种情况，则不会执行；
#endif
#include <pthread.h>
#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <semaphore.h>
sem_t sm0,sm1,sm2,sm3; //信号量定义信号量为控制线程的执行
void ret_fn(void*str)//线程退出调用的回调函数
{
fputs(str,stdout);
}
void thread0(void)
{
if(0 != sem_wait(&sm0))//信号量进行阻塞
{
perror("sem_wait_0");
}
char *str = "thead0_return_FN is runing\n";
pthread_cleanup_push(ret_fn,str);//将回调函数入栈
fputs("thread0 is runing\n",stdout);
pthread_cleanup_pop(0);//将回调函数出栈，当遇到特定的条件会自动调用，不需要PC指到此才执行
return;
}
void thread1(void)
{
if(0 != sem_wait(&sm1))
{
perror("sem_wait_1");
}
char *str = "thead1_return_FN is runing\n";
pthread_cleanup_push(ret_fn,str);
fputs("thread1 is runing\n",stdout);
pthread_exit((void*)1);
pthread_cleanup_pop(0);
}
void thread2(void)
{
if(0 != sem_wait(&sm2))
{
perror("sem_wait_2");
}
char *str = "thead2_return_FN is runing\n";
pthread_cleanup_push(ret_fn,str);
fputs("thread2 is runing\n",stdout);
pthread_cleanup_pop(1);
fputs("线程结束才会执行pthread_cleanup_pop\n",stdout);//线程结束才会执行pthread_cleanup_pop
}
void thread3(void)
{
char *str = "thead3_return_FN is runing\n";
pthread_cleanup_push(ret_fn,str);
if(0 != sem_wait(&sm3))
{
perror("sem_wait_3");
}
fputs("thread3 is runing\n",stdout);
usleep(100);// 让主线程中的pthread_cancel可以执行
pthread_cleanup_pop(0);
}
int main(void)
{
pthread_t thd0,thd1,thd2,thd3;
if(0 != sem_init(&sm0,0,0))//初始化信号量
{
perror("sem_init_0");
exit(1);
}
if(0 != sem_init(&sm1,0,0))
{
perror("sem_init_0");
exit(1);
}
if(0 != sem_init(&sm2,0,0))
{
perror("sem_init_0");
exit(1);
}
if(0 != sem_init(&sm3,0,0))
{
perror("sem_init_0");
exit(1);
}
if(0 != pthread_create(&thd0,NULL,(void*)thread0,NULL))//创建线程
{
perror("pthread_create_0\n");
exit(1);
}
if(0 != pthread_create(&thd1,NULL,(void*)thread1,NULL))
{
perror("pthread_create_1\n");
exit(1);
}
if(0 != pthread_create(&thd2,NULL,(void*)thread2,NULL))
{
perror("pthread_create_2\n");
exit(1);
}
if(0 != pthread_create(&thd3,NULL,(void*)thread3,NULL))
{
perror("pthread_create_3\n");
exit(1);
}
unsigned char status = 0xF;//控制重复测试掩码
while(1)
{
fputs("请输入测试选项：0(没有调用回调函数),１(pthread_exit),2(pthread_cancel),3(参数非0 pthread_cleanup_pop)\n",stdout);
int in;
scanf("%d",&in);
switch(in)
{
case 0:
{
if(!(status & 0x1))
{
fputs("这个项目已测试过，请选择其它，谢谢\n",stdout);
break;
}
if(0 != sem_post(&sm0))//激活信号量，让子线程THD0继续执行
{
perror("sem_post_0\n");
}
status &= 0xe;
break;
}
case 1:
{
if(!(status & 0x2))
{
fputs("这个项目已测试过，请选择其它，谢谢\n",stdout);
break;
}
if(0 != sem_post(&sm1))
{
perror("sem_post_1\n");
}
status &= 0xc;
break;
}
case 2:
{
if(!(status & 0x4))
{
fputs("这个项目已测试过，请选择其它，谢谢\n",stdout);
break;
}
if(0 != sem_post(&sm2))
{
perror("sem_post_2\n");
}
status &= 0xb;
break;
}
case 3:
{
if(!(status & 0x8))
{
fputs("这个项目已测试过，请选择其它，谢谢\n",stdout);
break;
}
if(0 != sem_post(&sm3))
{
perror("sem_post_3\n");
}
pthread_cancel(thd3);
status &= 0x7;
break;
}
default: break;
}
sleep(1);
}
return 0;
}