Chinaunix

标题: 这个问题很难(进程组间通信问题) [打印本页]

作者: cxchao_cs 时间: 2008-01-16 17:19
标题: 这个问题很难(进程组间通信问题)
主线程创建三个子线程：thread1,thread2,thread3
这三个子线程里面均处理SIGTERM信号，在接收到此信号时让全局变量tmp++
然后再主线程里面调用kill(getpid(),SIGTERM)向当前进程发送SIGTERM信号
为什么只有第一个线程thread1能收到信号，其他两个线程收不到信号？

作者: flw2 时间: 2008-01-16 17:32
你是不是在线程create之后注册的函数

作者: drog1983 时间: 2008-01-16 19:54

原帖由 flw2 于 2008-1-16 17:32 发表
你是不是在线程create之后注册的函数

虚心请教一下,为什么在线程create之后注册的函数只有一个线程能够收到信号?

作者: flw2 时间: 2008-01-16 22:50
记错了，signal注册没有关系，改变的都是进程的东西
sigprogmask是在pthread_create之前还是之后就有关系了它改变的是线程的数据

当用kill(getpid()，SIGTERM）的时候，或者SIGTERM来自别的进程的时候，通常首选的是线程组里面的初始线程,但是如果这个时候信号正在那个线程上执行的时候，那么信号会选择别的线程执行(可以在信号函数里sleep一下，然后给它们发信号试试)

signal和多线程结合很复杂，信号应该被看着进程的东西，不依赖被哪个线程执行，如果某个线程不想处理信号，那么应该显示的sigprogmask。

[ 本帖最后由 flw2 于 2008-1-16 23:14 编辑 ]

作者: cxchao_cs 时间: 2008-01-18 11:10
很对不住大家，我现在才能回复

这个程序处理流程是这样的：
1，在主线程里面，对当前线程设置sig_mask(阻塞所有信号)
2，创建三个线程
3，在子线程里面，给SIGTERM信号设置信号处理函数：在接收到此信号时让全局变量tmp++(tmp初始化为1)
4，在主线程里面调用kill(getpid(),SIGTERM)向当前进程发送SIGTERM信号
5，在主线程里面调用pthread_join等待三个子线程执行完毕
6，判断tmp是否为1

作者: flw2 时间: 2008-01-18 11:11
这样的话信号应该被阻塞了呀，SIGTERM根本收不到吧

作者: cxchao_cs 时间: 2008-01-18 11:33
我把代码贴出来，呵呵
虽然代码有点长，但是结构很简单，大家可要耐着性子看下哦

int sig_handler1_called = 0;

void sig_handler1(int signo)
{
sig_handler1_called++;
}

void *sig_test1_t1(){

struct sigaction act;
sigset_t fillset,emptyset;

sigemptyset( &emptyset );
sigaddset( &emptyset, SIGTERM );
sigfillset( &fillset );
sigdelset( &fillset, SIGTERM );

act.sa_handler = sig_handler1;
act.sa_flags = 0;
sigemptyset(&act.sa_mask);

if( sigaction( SIGTERM, &act, 0 ) == -1 ){
printf( "## sig_test1 : t1 sigaction error rtnval = -1\n" );
pthread_exit((void*)1);
}
pthread_sigmask(SIG_BLOCK, &fillset, NULL);
pthread_sigmask(SIG_UNBLOCK, &emptyset, NULL);
sleep(10);

pthread_exit((void*)0);

}

void *sig_test1_t2(){

struct sigaction act;
sigset_t fillset,emptyset;

sigemptyset( &emptyset );
sigaddset( &emptyset, SIGTERM );
sigfillset( &fillset );
sigdelset( &fillset, SIGTERM );

act.sa_handler = sig_handler1;
act.sa_flags = 0;
sigemptyset(&act.sa_mask);

if( sigaction( SIGTERM, &act, 0 ) == -1 ){
printf( "## sig_test1 : t2 sigaction error rtnval = -1\n" );
pthread_exit((void*)1);
}
pthread_sigmask( SIG_BLOCK, &fillset, NULL );
pthread_sigmask( SIG_UNBLOCK, &emptyset, NULL );

sleep(10);
pthread_exit((void*)0);

}
void *sig_test1_t3(){

struct sigaction act;
sigset_t fillset,emptyset;

sigemptyset( &emptyset );
sigaddset( &emptyset, SIGTERM );
sigfillset( &fillset );
sigdelset( &fillset, SIGTERM );

act.sa_handler = sig_handler1;
act.sa_flags = 0;
sigemptyset(&act.sa_mask);

if( sigaction( SIGTERM, &act, 0 ) == -1 ){
printf( "## sig_test1 : t3 sigaction error rtnval = -1\n" );
pthread_exit((void*)1);
}
pthread_sigmask( SIG_SETMASK, &fillset, NULL );
pthread_sigmask( SIG_UNBLOCK, &emptyset, NULL );

sleep(10);

pthread_exit((void*)0);

}
void sig_test1(void){

int rtnval;
int *th_ret;
pthread_t thID[3];
sigset_t set;

rtnval = sigfillset( &set );
if( rtnval != 0 ){
printf( "## sig_test1 : main sigfillset error rtnval = %d\n", rtnval );
return;
}
rtnval = pthread_sigmask( SIG_BLOCK, &set, NULL );
if( rtnval != 0 ){
printf( "## sig_test1 : main pthread_sigmask error rtnval = %d\n", rtnval );
return;
}

rtnval = pthread_create( &thID[0], NULL, sig_test1_t1, NULL );
if( rtnval != 0 ){
printf( "## sig_test1 : t1 pthread_create error rtnval = %d\n", rtnval );
return;
}
rtnval = pthread_create( &thID[1], NULL, sig_test1_t2, NULL );
if( rtnval != 0 ){
printf( "## sig_test1 : t2 pthread_create error rtnval = %d\n", rtnval );
return;
}
rtnval = pthread_create( &thID[2], NULL, sig_test1_t3, NULL );
if( rtnval != 0 ){
printf( "## sig_test1 : t3 pthread_create error rtnval = %d\n", rtnval );
return;
}

sleep(3);
if( kill( getpid(), SIGTERM ) == -1 ){
printf( "## sig_test1 : main pthread_kill error rtnval = -1 \n" );
return;
}
rtnval = pthread_join( thID[0], (void*)&th_ret );
if( rtnval != 0 ){
printf( "## sig_test1 : t1 pthread_join error rtnval = %d\n", rtnval );
return;
}
rtnval = pthread_join( thID[1], (void*)&th_ret );
if( rtnval != 0 ){
printf( "## sig_test1 : t2 pthread_join error rtnval = %d\n", rtnval );
return;
}
rtnval = pthread_join( thID[2], (void*)&th_ret );
if( rtnval != 0 ){
printf( "## sig_test1 : t3 pthread_join error rtnval = %d\n", rtnval );
return;
}
if( th_ret != 0 || sig_handler1_called != 1 ){
printf( "## sig_test1 : t1 TEST FAIL \n" );
return;
}
printf( "## sig_test1 : PASS!\n" );
}

作者: cxchao_cs 时间: 2008-01-18 11:34
忘记说明一点：sig_test1是入口函数

作者: flw2 时间: 2008-01-18 11:39
请先告诉我，你的结论只有第一个线程thread1能收到信号怎么来的

作者: cxchao_cs 时间: 2008-01-18 11:44
在子线程的入口函数sig_test1_t1里面可以看出，这三个子线程都不阻塞SIGTERM信号
所以如果线程能接受到信号，肯定会执行信号处理函数，也就是sig_handler1_called++
我在thread1的入口sig_test1_t1里面，输出sig_handler1_called，发现是1，
而最后程序的结果是PASS,所以现在sig_handler1_called还是1，就是说只有thread1收到信号

提醒一下：sig_test1_t1、sig_test1_t2、sig_test1_t3三个线程入口函数的功能是一样的

[ 本帖最后由 cxchao_cs 于 2008-1-18 11:52 编辑 ]

作者: flw2 时间: 2008-01-18 11:47
我如果认为是线程2收到信号，你认为我错在哪？你的线程函数做的事情都是等待信号，然后把变量加一，无法区分是谁呀

作者: cxchao_cs 时间: 2008-01-18 11:54
如果是线程2接收到信号，它会执行信号处理函数
但是它相应完信号之后，其它两个线程就收不到这个信号了，很奇怪

作者: flw2 时间: 2008-01-18 11:55

原帖由 cxchao_cs 于 2008-1-18 11:54 发表
如果是线程2接收到信号，它会执行信号处理函数
但是它相应完信号之后，其它两个线程就收不到这个信号了，很奇怪

莫非你是要发一遍，然后3个线程都收到？

作者: cxchao_cs 时间: 2008-01-18 11:57
是这样的，因为kill向当前进程发信号，进程中的所有线程都应该能收到的

作者: flw2 时间: 2008-01-18 11:58
错了，最多一个收到

作者: cxchao_cs 时间: 2008-01-21 11:02
还有一个问题，怎样才能证明“最多一个收到”？:wink:

作者: flw2 时间: 2008-01-21 11:28
变量只被加了1次，就说明最多1次，这是公理，不是证明，而是验证

作者: popicer 时间: 2008-01-21 16:57
标题: 回复 #17 flw2 的帖子
是不是因为这个原因啊。
Linux中线程和他的父进程是共用信号的，因此在程序执行到某个地方的时候如果信号到了就会去执行他的处理函数，处理结束后会把该信号的标志位清零。所以一个进程的信号，在信号到来时只能执行一次该信号的处理函数，具体到楼主的程序，我觉得执行的函数应该是最后一个被注册的线程的处理函数，因为会覆盖前面两个线程的设置。
自己理解的不知对不对^_^

作者: cxchao_cs 时间: 2008-01-22 16:57
首先，我不明白你这句话是啥意思
“处理结束后会把该信号的标志位清零”，这里的标志位是哪个标志位

另外，是第一个线程响应了信号，而不是最后一个

作者: popicer 时间: 2008-01-22 17:06
标题: 回复 #19 cxchao_cs 的帖子
每一个进程都有一个32位的变量来描述他所拥有的信号，每个信号一位，如果信号到来的话就会置该位为1，进程在某个时刻会检查是否有信号到来，有的话就去执行，然后清零该位，等待信号的再次到来。

作者: cxchao_cs 时间: 2008-01-23 15:35
首先，那个32位的变量叫做信号掩码(sig_mask)，但是不一定是32位，它是用来阻塞信号的
如果某个信号在sig_mask中被置1，则信号到来时候将其阻塞

其次，我感觉你的解释不怎么详细，应该说得更详细:wink:

作者: chenhj_wo 时间: 2008-01-23 20:23
这类问题以我现在的水平我是看不懂啦!
不过我想向各位大虾请教一下,想学习Linux更深入的东西(比如本贴讨论的内容),
应该看哪些书呢?如果哪位大虾有电子书共享出来那就更好了,小弟不胜感激.没有
电子书的话,列出书名,小弟同样不胜感激.

作者: popicer 时间: 2008-01-23 22:45
标题: 回复 #22 chenhj_wo 的帖子
信号其实可以看作软件层次上对中断的模拟，因此可以按照中断的方式去理解它。我记得看赵炯的“linux0.11内核详解”的时候好像在从内核空间返回用户空间的时候会检测是否有改进程的信号产生，有的话就响应，具体的我也记不太清了。我觉得你这个程序之所以只有一个线程响应了就是因为你只是发送了一个这样的信号。具体的你可以看看有关源码啊。

作者: popicer 时间: 2008-01-23 22:56
可以参考一下《情景分析》中的724页

欢迎光临 Chinaunix (http://bbs.chinaunix.net/)