Linux线程间通信之信号（十八）
1.Linux线程间通信之信号
在linux下，每个进程都有自己的signal mask，这个信号掩码指定哪个信号被阻塞，哪个不会被阻塞，通常用调用sigmask来处理。同时每个进程还有自己的signal action，这个行为集合指定了信号该如何处理，通常调用sigaction来处理。
2.信号安装函数
int sigaction(int signum,const struct sigaction *act ,struct sigaction *oldact);
功能：
指定的信号编号来设置该信号的处理函数。
参数：
signum：信号编号。
act：指向结构sigaction的一个实例的指针。
oldact：用来保存原来对信号的处理，可以为NULL。
返回值：
成功：0。
失败： -1。
3.添加所有信号到信号集函数
int sigfillset(sigset_t * set);
功能：
sigfillset()用来将参数set信号集初始化，然后把所有的信号加入到此信号集里。
参数：
set：信号集标识的地址，以后操作此信号集，对 set 进行操作就可以。
返回值：
成功：0。
失败： -1。
4.添加一个信号到信号集函数
int sigaddset(sigset_t *set, int signum);
功能：
添加一个的信号加入到此信号集里。
参数：
set：信号集标识的地址，以后操作此信号集，对 set 进行操作就可以。
signum：信号编号。
返回值：
成功：0。
失败： -1。
5.初始化信号集函数
int sigemptyset(sigset_t *set);
功能：
初始化信号集。
参数：
set：信号集标识的地址，以后操作此信号集，对 set 进行操作就可以。
返回值：
成功：0。
失败： -1。
6.向线程发送信号函数
int pthread_kill(thread_t tid, int sig);
功能：
向线程发送信号。
参数：
tid：线程ID。
sig：信号编号。
返回值：
成功：0。
失败： -1。
7.更改或检查调用线程的信号掩码函数
int pthread_sigmask(int how, const sigset_t *act, sigset_t *oldact);
功能：
更改或检查调用线程的信号掩码。
参数：
how：向当前的信号掩码中添加或删除或替换set。
act：信号屏蔽字。
oldact：为NULL，即可。
how说明：
SIG_BLOCK: 结果集是当前集合参数集的并集（把参数set中的信号添加到信号屏蔽字中）
SIG_UNBLOCK: 结果集是当前集合参数集的差集（把信号屏蔽字设置为参数set中的信号）
SIG_SETMASK: 结果集是由参数集指向的集（从信号屏蔽字中删除参数set中的信号）
返回值：
成功：0。
失败： -1。
8.参考代码：
//=============================================================================
// File Name : thread_signal.c
// Author : FengQQ
//
// Description : 信号
// Annotation :
//
// int pthread_kill(pthread_t thread,int sig);
// 向线程thread发送sig信号，成功返回0，失败返回错误码
//
// int sigaction(int signum,const truct sigaction *act,struct sigaction *oldact);
// 为信号signum设置处理函数，处理函数在sigaction中指定
// act.sa_mask 信号屏蔽字
// act.sa_handler 信号集处理程序
//
// int pthread_sigmask(int how,const sigset_t *set,sigset_t *oldset);
// 多线程信号屏蔽函数
// how = SIG_BLOCK:向当前的信号掩码中添加set，其中set表示要取消阻塞的信号组。
// SIG_UNBLOCK: 向当前的信号掩码中删除set，其中set表示要取消阻塞的信号组。
// SIG_SETMASK: 将当前的信号掩码替换为set，其中set表示新的信号掩码。
// 在多线程中，新线程的当前信号掩码会继承创造它的线程的信号掩码
//
// Created by FengQQ. 2020-10-05
//=============================================================================
#include <stdio.h>
#include <pthread.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <sys/types.h>
#include <signal.h>
#include <errno.h>
//-------------信号回调函数1-----------------
void sig_handler1(int arg)
{
printf("pthread1 get signal\r\n");
return;
}
//-------------信号回调函数2-----------------
void sig_handler2(int arg)
{
printf("pthread2 get signal\r\n");
return;
}
//---------------线程函数1------------------
void *pthread1_callback(void *arg)
{
struct sigaction act;
printf("new pthread 1\r\n");
memset(&act,0,sizeof(act)); //将act的内存空间填入0
sigaddset(&act.sa_mask,SIGQUIT); //添加一个信号至信号集
act.sa_handler = sig_handler1;
sigaction(SIGQUIT,&act,NULL); //查询或设置信号处理方式
pthread_sigmask(SIG_BLOCK,&act.sa_mask,NULL);
sleep(2);
}
//---------------线程函数2------------------
void *pthread2_callback(void *arg)
{
struct sigaction act;
printf("new pthread 2\r\n");
memset(&act,0,sizeof(act)); //将act的内存空间填入0
sigaddset(&act.sa_mask,SIGQUIT); //添加一个信号至信号集
act.sa_handler = sig_handler2;
sigaction(SIGQUIT,&act,NULL); //查询或设置信号处理方式
//pthread_sigmask(SIG_BLOCK,&act.sa_mask,NULL);
sleep(2);
}
int main(int argc,char *argv[])
{
int ret;
int signal_value;
pthread_t ptid1,ptid2;
ret = pthread_create(&ptid1,NULL,pthread1_callback,NULL);
if(ret != 0)
{
printf("create new pthread1 failed...\r\n");
return -1;
}
ret = pthread_create(&ptid2,NULL,pthread2_callback,NULL);
if(ret != 0)
{
printf("create new pthread2 failed...\r\n");
return -1;
}
sleep(1);
signal_value = pthread_kill(ptid1,SIGQUIT);
if(signal_value != 0)
{
printf("send signal to thread1 failed...\r\n");
}
signal_value = pthread_kill(ptid2,SIGQUIT);
if(signal_value != 0)
{
printf("send signal to thread2 failed...\r\n");
}
ret = pthread_join(ptid1,NULL);
if(ret != 0)
{
printf("pthread1 join failed...\r\n");
}
ret = pthread_join(ptid2,NULL);
if(ret != 0)
{
printf("pthread2 join failed...\r\n");
}
return 0;
}
Linux线程间通信之信号量（十九）
链接: link.(https://blog.csdn.net/qq_39721016/article/details/120604654?spm=1001.2014.3001.5501)