首页 > 代码库 > 多线程异步管理——信号

多线程异步管理——信号

#include <stdio.h>#include <pthread.h>#include <stdlib.h>#include <unistd.h>#include <signal.h>void *sigone_program(void *arg);void *sigtwo_program(void *arg);void report(int);int main(int argc,char *argv[]){    int i;    void *status;    pthread_t thread_one,thread_two;    if(pthread_create(&thread_one,NULL,sigone_program,NULL)!=0)    {        fprintf(stderr,"pthread_create failure\n");        exit(EXIT_FAILURE);    }    if(pthread_create(&thread_two,NULL,sigtwo_program,NULL)!=0)    {        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)    {        perror("pthread_kill");        exit(EXIT_FAILURE);    }    if(pthread_kill(thread_one,SIGUSR2)!=0)    {        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)    {        perror("pthread_kill");        exit(EXIT_FAILURE);    }    if(pthread_kill(thread_two,SIGUSR2)!=0)    {        perror("pthread_kill");        exit(EXIT_FAILURE);    }    sleep(1);    if(pthread_kill(thread_one,SIGKILL)!=0)    {        perror("pthread_kill");        exit(EXIT_FAILURE);    }    if(pthread_kill(thread_two,SIGKILL)!=0)    {        perror("pthread_kill");        exit(EXIT_FAILURE);    }    pthread_join(thread_two,NULL);    pthread_join(thread_one,NULL);    return 0;}void *sigone_program(void *arg){    int i;    __sigset_t set;    signal(SIGUSR1,report);    sigfillset(&set);    sigdelset(&set,SIGUSR2);    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);    for(i=0;i<5;i++)    {        printf("this is no set mask %u thread\n",pthread_self());        pause();    }}