Search code examples
clinuxmultithreadingpthreadssignals

Which thread handles the signal?


I have 2 threads(thread1 and thread2). And I have signal disposition for SIGINT. Whenever SIGINT occurs thread 2 should handle the signal. For that I wrote below program

#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);
}

I compiled and and run the program. for every 1 second "thread1 active" is printing and for every 3 seconds "thread2 active" is printing.

Now I generated SIGINT. But its printing "thread1 active" and "thread2 active" messages like above. Again I generated SIGINT, now for every 3 seconds only "thread2 active" message is printing. Again I generated SIGINT, now all threads are blocked.

So I understood, for first time main thread executing signal handler. For second time thread1 executing handler and lastly thread2 executing signal handler.

How I can write the code like whenever signal occurs, only thread2 have to execute my signal handler?


Solution

  • If you send a signal to a process, which thread in the process will handle this signal is undetermined.

    According to pthread(7):

    POSIX.1 also requires that threads share a range of other attributes (i.e., these attributes are process-wide rather than per-thread):
    ...
    - signal dispositions
    ...

    POSIX.1 distinguishes the notions of signals that are directed to the process as a whole and signals that are directed to individual threads. According to POSIX.1, a process-directed signal (sent using kill(2), for example) should be handled by a single, arbitrarily selected thread within the process.


    If you want a dedicated thread in your process to handle some signals, here is an example from pthread_sigmask(3) shows you how to do it:

    The program below blocks some signals in the main thread, and then creates a dedicated thread to fetch those signals via sigwait(3). The following shell session demonstrates its use:

    $ ./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
    

    Program source

    #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 */
    }