pthread_sigmask
时间: 2023-09-13 18:04:15 浏览: 42
pthread_sigmask()函数用于设置线程的信号屏蔽字,即控制线程对信号的屏蔽和响应。
该函数的原型如下:
```c
int pthread_sigmask(int how, const sigset_t *set, sigset_t *oldset);
```
参数说明:
- `how`:用于指定如何修改信号屏蔽字的方式,可以是以下值之一:
- `SIG_BLOCK`:将`set`中的信号添加到当前信号屏蔽字中。
- `SIG_UNBLOCK`:将`set`中的信号从当前信号屏蔽字中移除。
- `SIG_SETMASK`:将当前信号屏蔽字设置为`set`中的值。
- `set`:指向要修改的新的信号屏蔽字的指针。
- `oldset`:可选参数,用于保存旧的信号屏蔽字的指针。
函数返回值为0表示成功,否则表示失败。
调用pthread_sigmask()函数可以修改线程的信号屏蔽字,从而控制线程对特定信号的响应方式。例如,可以通过该函数将某个信号添加到线程的信号屏蔽字中,使得线程在收到该信号时不做出任何响应。
相关问题
int main(int argc, char ** argv) { //线程调度相关 struct sched_param svparam = { .sched_priority = 71 }; pthread_attr_t svattr; sigset_t set; int sig; sigemptyset( & set); sigaddset( & set, SIGINT); sigaddset( & set, SIGTERM); sigaddset( & set, SIGHUP); pthread_sigmask(SIG_BLOCK, & set, NULL); pthread_attr_init( & svattr); pthread_attr_setdetachstate( & svattr, PTHREAD_CREATE_JOINABLE); pthread_attr_setinheritsched( & svattr, PTHREAD_EXPLICIT_SCHED); pthread_attr_setschedpolicy( & svattr, SCHED_FIFO); pthread_attr_setschedparam( & svattr, & svparam); errno = pthread_create( & svtid, & svattr, & server, NULL); if (errno) fail("pthread_create"); sigwait( & set, & sig); pthread_cancel(svtid); pthread_join(svtid, NULL); return 0; } 以上代码汇总sigwait函数的作用以及set的作用
以上代码中,`sigwait()` 函数的作用是阻塞等待指定的信号集中的信号,直到其中一个信号被捕获到。`sigwait()` 函数的原型为:
```c
int sigwait(const sigset_t *set, int *sig);
```
其中,`set` 是一个指向信号集的指针,它包含了要等待的信号;`sig` 是一个指向整数的指针,用于存储捕获到的信号的编号。
在给定的代码中,首先使用 `sigemptyset()` 函数清空了 `set` 信号集,然后使用 `sigaddset()` 函数向 `set` 中添加了三个信号:`SIGINT`、`SIGTERM` 和 `SIGHUP`。这意味着程序将等待这三个信号中的任何一个。
然后,通过调用 `pthread_sigmask()` 函数将 `set` 信号集设置为线程的信号掩码,以阻塞这三个信号。这样,当线程执行到 `sigwait()` 函数时,它将被阻塞,直到其中一个信号被捕获到。
最后,通过调用 `sigwait()` 函数等待信号,并将捕获到的信号存储在 `sig` 变量中。接下来的代码根据捕获到的不同信号做出相应的处理。
总结起来,以上代码使用 `sigwait()` 函数和信号集 `set` 实现了线程的同步等待,直到捕获到指定的信号。
#include <stdio.h> #include <stdlib.h> #include <string.h> #include <errno.h> #include <pthread.h> #include <signal.h> int quitflag; sigset_t mask; pthread_mutex_t lock = PTHREAD_MUTEX_INITIALIZER; pthread_cond_t wait = PTHREAD_COND_INITIALIZER; void *thr_fn(void *arg) { int err, signo; while(1) { err = sigwait(&mask, &signo); if (err != 0) { printf("sigwait failed: %s\n", strerror(err)); exit(1); } switch (signo) { case SIGINT: printf("\ninterrupt\n"); break; case SIGQUIT: pthread_mutex_lock(&lock); quitflag = 1; pthread_mutex_unlock(&lock); pthread_cond_signal(&wait); return 0; default: printf("unexpected signal %d\n", signo); exit(1); } } } int main() { int err; sigset_t oldmask; pthread_t tid; sigemptyset(&mask); sigaddset(&mask, SIGINT); sigaddset(&mask, SIGQUIT); if ((err = pthread_sigmask(SIG_BLOCK, &mask, &oldmask)) != 0) { printf("SIG_BLOCK error: %s\n", strerror(err)); exit(1); } err = pthread_create(&tid, 0, thr_fn, 0); if (err != 0) { printf("can't create thread: %s\n", strerror(err)); exit(1); } pthread_mutex_lock(&lock); while (quitflag == 0) pthread_cond_wait(&wait, &lock); pthread_mutex_unlock(&lock); quitflag = 0; if (sigprocmask(SIG_SETMASK, &oldmask, 0) < 0) { printf("SIG_SETMASK error: %s\n", strerror(err)); exit(1); } exit(0); }
这段代码是一个使用线程和信号处理机制的程序,它创建了一个线程来等待捕获到 SIGINT 或 SIGQUIT 信号,并在接收到 SIGQUIT 信号时通知主线程退出。具体来说,程序首先定义了一个 quitflag 变量和一个 signal mask,它们用于线程和主线程之间的同步和通信。然后程序创建一个线程,该线程使用 sigwait 函数等待信号,接收到 SIGINT 信号时输出 "interrupt",接收到 SIGQUIT 信号时将 quitflag 置为 1,并通过 signal 来通知主线程。主线程在等待期间会一直等待条件变量 wait 的信号,并在接收到信号时将 quitflag 重新置为 0,然后退出程序。此外,程序还使用了互斥锁来保护共享变量 quitflag 和条件变量 wait。