恳求指教！！一个线程异步信号的问题

nervfzb

我想做一个程序的效果是线程在得到主控制的进程发出的信号的时候才会运行，但是在运行的时候发现线程注册的信号回调函数不能工作，我看书上说的线程本质也是轻量的进程，而且本身也有信号处理机制。但是这个信号回调函数为何没有反应？
程序如下

1. 
   
2. #include <stdio.h>
   
3. #include <stdlib.h>
   
4. #include <stdint.h>
   
5. #include <string.h>
   
6. #include <unistd.h>
   
7. #include <signal.h>
   
8. #include <errno.h>
   
9. 
   
10. /**
    
11. * 搭建一个线程，开始阻塞，然后
    
12. * 遇到一个信号后解除阻塞，开始
    
13. * 工作
    
14. */
    
15. //线程控制结构体
    
16. typedef struct pthread_control
    
17. {
    
18.         uint8_t flag:1;
    
19.         uint8_t flag_b:1;
    
20.         uint8_t flag_c:1;
    
21.         uint8_t flag_d:1;
    
22.         uint8_t flag_e:1;
    
23.         uint8_t flag_f:1;
    
24.         uint8_t flag_g:1;
    
25.         uint8_t flag_h:1;
    
26.         pthread_mutex_t num_mutex;
    
27. } pth_ctrl;
    
28. 
    
29. #define        PTHREAD_ON_SIG        SIGRTMIN+3
    
30. #define        PTHREAD_OFF_SIG        SIGRTMAX-3
    
31. 
    
32. void pth_on(int signo)
    
33. {
    
34.         puts("pthread now on\n");
    
35. }
    
36. 
    
37. //线程
    
38. void *p_func(void *arg)
    
39. {
    
40.         uint32_t count = 0;
    
41.         pth_ctrl *p_c = (pth_ctrl *)arg;
    
42.         //安装一个信号处理函数
    
43.         signal(PTHREAD_ON_SIG,pth_on);//开启线程信号处理函数
    
44.         //线程的异步信号只接收指定信号集给定的信号
    
45.         sigset_t p_func_sig;
    
46.         sigemptyset(&p_func_sig);//初始化一个空信号集
    
47.         sigaddset(&p_func_sig,PTHREAD_ON_SIG);//填加一个信号集
    
48.         int sig_arv;//到达的信号
    
49.         uint8_t ctrl_flag;
    
50.         while(1)
    
51.         {
    
52.                 pthread_mutex_lock(&(p_c->num_mutex));
    
53.                 ctrl_flag = p_c->flag;
    
54.                 pthread_mutex_unlock(&(p_c->num_mutex));
    
55.                 if(ctrl_flag)
    
56.                 {
    
57.                         sigwait(&p_func_sig,&sig_arv);
    
58.                         //p_c->flag = ~(p_c->flag);
    
59.                         puts("thread on do what you want\n");
    
60.                         ctrl_flag = !ctrl_flag;
    
61.                 }
    
62.                 pthread_mutex_lock(&(p_c->num_mutex));
    
63.                 p_c->flag = ctrl_flag;
    
64.                 pthread_mutex_unlock(&(p_c->num_mutex));
    
65.                 printf("run %d times\n",count++);
    
66.                 sleep(1);
    
67.         }
    
68. }
    
69. 
    
70. 
    
71. int main(int argc,char *argv[])
    
72. {
    
73.         //初始化这个控制结构体
    
74.         pth_ctrl p_c;
    
75.         memset(&p_c,0,sizeof(pth_ctrl));
    
76.         p_c.flag = 1;
    
77.         //线程初始化
    
78.         pthread_t newthid;
    
79.         if(pthread_create(&newthid,NULL,p_func,&p_c) != 0)
    
80.         {
    
81.                 perror("thread create failed");
    
82.                 return -1;
    
83.         }
    
84.         //注册一个信号，采用定时器的方式
    
85.         //在一定的时间向线程发送信号
    
86.         //signal(PTHREAD_CTRL_TIMER,
    
87.         while(1)
    
88.         {
    
89.                 //定时器发送信号
    
90.                 sleep(5);
    
91.                 pthread_kill(newthid,PTHREAD_ON_SIG);
    
92.                 sleep(5);
    
93.                 //这里应该使用一个互斥体
    
94.                 //将控制标志锁住，防止影
    
95.                 //响其他线程
    
96.                 pthread_mutex_lock(&(p_c.num_mutex));
    
97.                 p_c.flag = 1;
    
98.                 pthread_mutex_unlock(&(p_c.num_mutex));
    
99.         }
    
100.         return 0;
     
101. }
     

复制代码

这个程序运行的效果

1. 
   
2. thread on do what you want
   
3. 
   
4. run 0 times
   
5. run 1 times
   
6. run 2 times
   
7. run 3 times
   
8. run 4 times
   
9. thread on do what you want
   
10. 
    
11. run 5 times
    
12. run 6 times
    
13. run 7 times
    
14. run 8 times
    
15. run 9 times
    
16. ....
    

复制代码

这个程序运行的时候线程等待进程发送信号，然后解除阻塞运行，然后运行一段时间后，主线程修改和进程共用的一个变量然后线程重新进入阻塞状态。但是就是没有发现主进程发送信号的时候，线程注册的信号函数被调用（本来应该打印一句话）。不知道是不是使用方法没有对？？恳求指教！！谢谢！！

qqrilxk

linux 多线程信号总结(一)
1. 在多线程环境下，产生的信号是传递给整个进程的，一般而言，所有线程都有机会收到这个信号，进程在收到信号的的线程上下文执行信号处理函数，具体是哪个线程执行的难以获知。
2 signal函数 BSD/Linux的实现并不在信号处理函数调用时，恢复信号的处理为默认，而是在信号处理时阻塞此信号，直到信号处理函数返回。其他实现可能在调用信号处理函数时，恢复信号的处理为默认方式，因而需要在信号处理函数中重建信号处理函数为我们定义的处理函数，在这些系统中，较好的方法是使用sigaction来建立信号处理函数。
3 发送信号给进程，哪个线程会收到？ APUE说，在多线程的程序中，如果不做特殊的信号阻塞处理，当发送信号给进程时，由系统选择一个线程来处理这个信号。
4 如果进程中，有的线程可以屏蔽了某个信号，而某些线程可以处理这个信号，则当我们发送这个信号给进程或者进程中不能处理这个信号的线程时，系统会将这个信号投递到进程号最小的那个可以处理这个信号的线程中去处理。
5 如果我们同时注册了信号处理函数，同时又用sigwait来等待这个信号，谁会取到信号？经过实验，Linux上sigwait的优先级高。6 在Linux中的posix线程模型中，线程拥有独立的进程号，可以通过getpid()得到线程的进程号，而线程号保存在pthread_t的值中。而主线程的进程号就是整个进程的进程号，因此向主进程发送信号只会将信号发送到主线程中去。如果主线程设置了信号屏蔽，则信号会投递到一个可以处理的线程中去。
7 当调用SYSTEM函数去执行SHELL命令时，可以放心的阻塞SIGCHLD，因为SYSTEM会自己处理子进程终止的问题。
8 使用sleep()时，要以放心的去阻塞SIGALRM信号，目前sleep函数都不会依赖于ALRM函数的SIGALRM信号来工作。

djsxut

sigwait的第二个参数是返回的信号值，你在后面进行判断，例如：

sigwait(&p_func_sig,&sig_arv);

if (PTHREAD_ON_SIG == sig_arv)
{
  puts("test: pthread now on\n");
}