这个问题很难(进程组间通信问题)

cxchao_cs

主线程创建三个子线程：thread1,thread2,thread3
这三个子线程里面均处理SIGTERM信号，在接收到此信号时让全局变量tmp++
然后再主线程里面调用kill(getpid(),SIGTERM)向当前进程发送SIGTERM信号
为什么只有第一个线程thread1能收到信号，其他两个线程收不到信号？

cxchao_cs

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

cxchao_cs

我把代码贴出来，呵呵
虽然代码有点长，但是结构很简单，大家可要耐着性子看下哦
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

忘记说明一点：sig_test1是入口函数

cxchao_cs

在子线程的入口函数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 编辑 ]

cxchao_cs

如果是线程2接收到信号，它会执行信号处理函数
但是它相应完信号之后，其它两个线程就收不到这个信号了，很奇怪

cxchao_cs

是这样的，因为kill向当前进程发信号，进程中的所有线程都应该能收到的

cxchao_cs

还有一个问题，怎样才能证明“最多一个收到”？:wink:

cxchao_cs

首先，我不明白你这句话是啥意思
“处理结束后会把该信号的标志位清零”，这里的标志位是哪个标志位

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

cxchao_cs

首先，那个32位的变量叫做信号掩码(sig_mask)，但是不一定是32位，它是用来阻塞信号的
如果某个信号在sig_mask中被置1，则信号到来时候将其阻塞

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