C语言 哪个线程处理信号?

rhfm7lfc  于 2023-03-17  发布在  其他
关注(0)|答案(2)|浏览(158)

我有两个线程(线程1和线程2)。我有SIGINT的信号处理。每当SIGINT发生时,线程2应该处理信号。为此,我编写了以下程序

#include <pthread.h>
#include <signal.h>
#include <stdio.h>

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 t2;

    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必须执行我的信号处理程序?

ncecgwcz

ncecgwcz1#

如果向进程发送信号,则进程中的哪个线程将处理此信号是不确定的。
根据pthread(7)
POSIX. 1还要求线程共享一系列其他属性(即,这些属性是进程范围的,而不是每个线程的):
...

  • 信号配置
    ...
    POSIX. 1区分了指向整个进程的信号和指向单个线程的信号。根据POSIX. 1,一个指向进程的信号(例如,使用kill(2)发送)应该由进程中的一个单一的、任意选择的线程处理。
    如果您希望进程中有一个专用线程来处理某些信号,下面是pthread_sigmask(3)中的一个示例,向您展示了如何做到这一点:
    下面的程序阻塞了主线程中的一些信号,然后创建了一个专用线程来通过sigwait(3)获取这些信号用途:
$ ./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 */
}
djp7away

djp7away2#

仔细阅读signal(7)pthread(7)pthread_kill(3)sigprocmask(2)pthread_sigmask(3)--你可以使用它们(阻止不需要的线程中的SIGINT)。
避免使用信号在线程之间进行通信或同步。考虑互斥锁(pthread_mutex_lock等)和条件变量(pthread_cond_wait等)。
如果其中一个线程运行event loop(例如poll(2)附近...),请考虑使用signalfd(2)

相关问题