我有2个线程(线程1和线程2)。而且我有信号处理SIGINT。每当SIGINT发生线程2时,都应处理该信号。为此,我写了下面的程序
SIGINT
void sig_hand(int no) //signal handler { printf("handler executing...\n"); getchar(); } void* thread1(void *arg1) //thread1 { while(1) { printf("thread1 active\n"); sleep(1); } } void * thread2(void * arg2) //thread2 { signal(2, sig_hand); while(1) { printf("thread2 active\n"); sleep(3); } } int main() { pthread_t t1; pthread_t t1; pthread_create(&t1, NULL, thread1, NULL); pthread_create(&t2, NULL, thread2, NULL); while(1); }
我编译并运行该程序。每1秒打印一次“ thread1 active”,每3秒打印一次“ thread2 active”。
现在我生成了SIGINT。但是它会像上面那样显示“ thread1 active”和“ thread2 active”消息。再次生成了SIGINT,现在每3秒仅打印一次“ thread2 active”消息。再次生成SIGINT,现在所有线程都被阻塞。
所以我明白了,第一次主线程执行信号处理程序。第二次线程1执行处理程序,最后线程2执行信号处理程序。
我怎样才能像发生信号时一样编写代码,只有thread2才能执行我的信号处理程序?
如果将信号发送给进程,则该进程中的哪个线程将处理该信号尚未确定。
根据pthread(7):
pthread(7)
POSIX.1还要求线程共享一系列其他属性(即,这些属性是进程范围而不是每个线程的属性): …- 信号处置 … POSIX.1区分了针对整个过程的信号和针对各个线程的信号的概念。根据POSIX.1,过程控制信号(kill(2)例如,使用发送)应由过程中的单个 任意 选择的线程处理。
POSIX.1还要求线程共享一系列其他属性(即,这些属性是进程范围而不是每个线程的属性): …- 信号处置 …
POSIX.1区分了针对整个过程的信号和针对各个线程的信号的概念。根据POSIX.1,过程控制信号(kill(2)例如,使用发送)应由过程中的单个 任意 选择的线程处理。
kill(2)
如果您希望进程中的专用线程处理某些信号,请参见以下示例,其中pthread_sigmask(3)显示了操作方法:
pthread_sigmask(3)
下面的程序在主线程中阻塞了一些信号,然后创建了一个专用线程来通过sigwait(3)获取这些信号。以下shell会话演示了其用法:
$ ./a.out & [1] 5423 $ kill -QUIT %1 Signal handling thread got signal 3 $ kill -USR1 %1 Signal handling thread got signal 10 $ kill -TERM %1 [1]+ Terminated ./a.out
节目来源
#include <pthread.h> #include <stdio.h> #include <stdlib.h> #include <unistd.h> #include <signal.h> #include <errno.h> /* Simple error handling functions */ #define handle_error_en(en, msg) \ do { errno = en; perror(msg); exit(EXIT_FAILURE); } while (0) static void * sig_thread(void *arg) { sigset_t *set = arg; int s, sig; for (;;) { s = sigwait(set, &sig); if (s != 0) handle_error_en(s, "sigwait"); printf("Signal handling thread got signal %d\n", sig); } } int main(int argc, char *argv[]) { pthread_t thread; sigset_t set; int s; /* Block SIGQUIT and SIGUSR1; other threads created by main() will inherit a copy of the signal mask. */ sigemptyset(&set); sigaddset(&set, SIGQUIT); sigaddset(&set, SIGUSR1); s = pthread_sigmask(SIG_BLOCK, &set, NULL); if (s != 0) handle_error_en(s, "pthread_sigmask"); s = pthread_create(&thread, NULL, &sig_thread, (void *) &set); if (s != 0) handle_error_en(s, "pthread_create"); /* Main thread carries on to create other threads and/or do other work */ pause(); /* Dummy pause so we can test program */ }