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 #include #include #include #include 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; }
版权声明：本文内容由网络用户投稿，版权归原作者所有，本站不拥有其著作权，亦不承担相应法律责任。如果您发现本站中有涉嫌抄袭或描述失实的内容，请联系我们jiasou666@gmail.com 处理，核实后本网站将在24小时内删除侵权内容。
暂时没有评论，来抢沙发吧~