Linux--线程信号详解及demo分析

女爷i 2022-11-27 03:17 79阅读 0赞

### 线程信号 ###

*  每个线程可以向其他线程发送信号 pthread\_kill
 *  每个信号都有信号屏蔽集合
 *  同进程下所有线程共享对某信号的处理方法

线程信号发送

int pthread_kill(pthread_t thread, int sig);

参数：  
pthread\_t thread：线程ID  
int sig：信号值，Linux中的32个信号

线程的信号屏蔽集合：

int pthread_sigmask(int how, const sigset_t *set, sigset_t *oldset);

参数：  
int how：  
SIG\_BLOCK 锁定  
SIG\_UNBLOCK 解锁  
SIG\_SETMASK 屏蔽集合

const sigset\_t \*set：信号  
sigset\_t \*oldset：备份数据，一般置空

不论给进程中的哪个线程发送SIG\_KILL SIG\_STOP 则当前进程中的所有线程都会推出

### demo ###

#include<stdio.h>
    #include<pthread.h>
    #include<stdlib.h>
    #include<unistd.h>
    #include<signal.h>
    void *sigone_program(void *arg);  //线程1执行函数
    void *sigtwo_program(void *arg);   //线程2执行函数
    void report(int);
    pthread_t thread_one,thread_two;  //定义线程1，2的ID
    
    int main(int argc,char *argv[])
    { 
            int i;
            void *status;  
    	if(pthread_create(&thread_one,NULL,sigone_program,NULL)!=0)  //创建线程1
            { 
                    fprintf(stderr,"pthread_create failure\n");
                    exit(EXIT_FAILURE);
            }
            if(pthread_create(&thread_two,NULL,sigtwo_program,NULL)!=0)  //创建线程2
            { 
                    fprintf(stderr,"pthread_create failure\n");
                    exit(EXIT_FAILURE);
            }
            sleep(1);
    
            printf("this is parent ,send SIGUSR1,SIGUSR2 to thread %u\n",thread_one);
    
            if(pthread_kill(thread_one,SIGUSR1)!=0)  //给线程1发送user1信号
            { 
                    perror("pthread_kill");
                    exit(EXIT_FAILURE);
            }
    
            if(pthread_kill(thread_one,SIGUSR2)!=0)  //给线程1发送user2信号
            { 
                    perror("pthread_kill");
                    exit(EXIT_FAILURE);
            }
    
    
            printf("this is parent ,send SIGUSR1,SIGUSR2 to thread %u\n",thread_two);
            if(pthread_kill(thread_two,SIGUSR1)!=0)   //给线程1发送user1信号
            { 
                    perror("pthread_kill");
                    exit(EXIT_FAILURE);
            }
            if(pthread_kill(thread_two,SIGUSR2)!=0)  //给线程2发送user2信号
            { 
                    perror("pthread_kill");
                    exit(EXIT_FAILURE);
            }
    	sleep(1);
    	if(pthread_kill(thread_one,SIGKILL)!=0)   //给线程1发送结束信号
            { 
                    perror("pthread_kill");
                    exit(EXIT_FAILURE);
            }
    
            printf("the end\n");
            pthread_join(thread_two,NULL);  //等待线程2结束
            pthread_join(thread_one,NULL); //等待线程1结束
            return 0;
    }
    void *sigone_program(void *arg)
    { 
            int i;
            __sigset_t set;
    	signal(SIGUSR1,report);  //给USER1绑定回调函数
            sigfillset(&set);    //填满信号屏蔽集合
            sigdelset(&set,SIGUSR2);   //把USER2信号从屏蔽集合中删除
    	pthread_sigmask(SIG_SETMASK,&set,NULL);  //设置线程屏蔽集合
            for(i=0;i<5;i++)
            { 
                printf("this is set mask %u thread\n",pthread_self());
            	pause();
    	    }
    }
    void report(int sig)
    { 
            printf("\nin signal ,the sig=%d\t,the thread id=%u\n",sig,pthread_self());
    }
    
    void *sigtwo_program(void *arg)
    { 
            int i;
            signal(SIGUSR2,report);  //给USER2绑定回调函数
            for(i=0;i<5;i++)
            { 
                    printf("this is no set mask %u thread\n",pthread_self());
            	pause();
    	}
    }

#### 运行结果及分析 ####

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NTMwOTkxNg_size_16_color_FFFFFF_t_70_pic_center]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NTMwOTkxNg_size_16_color_FFFFFF_t_70_pic_center]: /images/20221124/1a477827d4d34f87bd454e9c43acfa26.png