2024.2.23
- 创业
- 2026-07-15 13:30:02
1.1.1 信号默认、捕获、忽略处理(普通信号)
#include <myhead.h>
void handler(int signo)
{
if(signo==SIGINT){
printf("用户键入 ctrl+c\n");
}
}
int main(int argc, const char *argv[])
{
//忽略信号
if(signal(SIGINT,SIG_IGN)==SIG_ERR){
perror("signal error");
return -1;
}
/*
//默认处理信号
if(signal(SIGINT,SIG_IGN)==SIG_ERR){
perror("signal error");
return -1;
}
//捕获信号
if(signal(SIGINT,handler)==SIG_ERR){
perror("signal error");
return -1;
}
*/
while(1)
{
printf("123456\n");
sleep(1);
}
return 0;
}
1.1.2 SIGCHLD回收僵尸进程
#include <myhead.h>
void handler(int signo)
{
if(signo==SIGCHLD){
while(waitpid(-1,NULL,WNOHANG)>0);
//waitpid(-1,NULL,WNOHANG);
}
}
int main(int argc, const char *argv[])
{
//捕获信号
if(signal(SIGCHLD,handler)==SIG_ERR){
perror("signal error");
return -1;
}
//创建僵尸进程
for(int i=0;i<5;i++)
{
if(fork()==0){
sleep(1);
exit(EXIT_SUCCESS);
}
}
while(1);
return 0;
}
1.1.3 模拟出牌
#include <myhead.h>
//信号处理函数
void handler(int signo)
{
if(signo==SIGALRM){
printf("系统为您出了一张牌\n");
alarm(5);
}
}
int main(int argc, const char *argv[])
{
//捕获SIGALRM信号
if(signal(SIGALRM,handler)==SIG_ERR){
perror("signal error");
return -1;
}
alarm(5); //启动定时器
//出的牌
char ch=0;
while(1)
{
scanf("%c",&ch);
getchar();
printf("你出的牌为:%c\n",ch);
alarm(5);
}
return 0;
}
1.1.4 发送信号函数
#include <myhead.h>
void hander(int signo)
{
if(signo==SIGUSR1){
printf("大清亡了\n");
raise(SIGKILL);
}
}
int main(int argc, const char *argv[])
{
//发送信号
if(signal(SIGUSR1,hander)==SIG_ERR){
perror("signal error");
return -1;
}
//创建进程
pid_t pid=fork();
if(pid>0){
//父进程
while(1)
{
printf("这是朕的江山\n");
sleep(1);
}
}else if(pid==0){
//子进程
sleep(3);
printf("我才是真命天子\n");
kill(getppid(),SIGUSR1);
while(1)
{
printf("现在是我的了\n");
sleep(1);
}
}else{
perror("pid error");
return -1;
}
return 0;
}
1.2 消息队列
msgsnd.c:
#include <myhead.h> //消息队列结构体 struct msgbuf { long mtype; char mtest[1024]; }; //宏表示消息正文的大小 #define MSGSIZE sizeof(struct msgbuf)-sizeof(long) int main(int argc, const char *argv[]) { //创建 key 值 key_t key=0; if((key=ftok("/",'k'))==-1){ perror("ftok error"); return -1; } printf("fork success key=%#x\n",key); //根据key值创建消息队列 int msqid=-1; if((msqid=msgget(key,IPC_CREAT|0664))==-1){ perror("msgget error"); return -1; } printf("msgget success msqid=%#x\n",msqid); //定义一个消息 struct msgbuf sbuf; while(1) { //清空正文的容器 bzero(sbuf.mtest,sizeof(sbuf.mtest)); printf("请输入当前消息的类型:"); scanf("%ld",&sbuf.mtype); getchar(); //吸收垃圾字符 printf("请输入消息正文:"); fgets(sbuf.mtest,sizeof(sbuf.mtest),stdin); sbuf.mtest[strlen(sbuf.mtest)-1]='\0'; //将消息存放到队列中 msgsnd(msqid,&sbuf,MSGSIZE,0); printf("发送成功\n"); if(strcmp(sbuf.mtest,"quit")==0){ break; } } return 0; }msgrcv.c:
#include <myhead.h> //消息队列结构体 struct msgbuf { long mtype; char mtest[1024]; }; //宏表示消息正文的大小 #define MSGSIZE sizeof(struct msgbuf)-sizeof(long) int main(int argc, const char *argv[]) { //创建 key 值 key_t key=0; if((key=ftok("/",'k'))==-1){ perror("ftok error"); return -1; } printf("fork success key=%#x\n",key); //根据key值创建消息队列 int msqid=-1; if((msqid=msgget(key,IPC_CREAT|0664))==-1){ perror("msgget error"); return -1; } printf("msgget success msqid=%#x\n",msqid); //定义一个消息 struct msgbuf rbuf; while(1) { //清空正文的容器 bzero(rbuf.mtest,sizeof(rbuf.mtest)); //从消息队列中读取一个消息 msgrcv(msqid,&rbuf,MSGSIZE,0,0); printf("收到的消息为:%s\n",rbuf.mtest); if(strcmp(rbuf.mtest,"quit")==0){ break; } } //删除消息队列 if(msgctl(msqid,IPC_RMID,NULL)!=0){ perror("msgctl error"); return -1; } return 0; } 作业2：使用消息队列完成两个进程间相互通信msgsnd.c:
#include <myhead.h> //定义一个消息类型 struct msgbuf { long mtype; char mtest[1024]; }; //宏表示消息正文大小 #define MSGSIZE sizeof(struct msgbuf)-sizeof(long) /*****************************主程序***********************/ int main(int argc, const char *argv[]) { //1、创建key值 key_t key=0; if((key=ftok("/",'k'))==-1){ perror("ftok error"); return -1; } //根据key值创建一个消息队列 int msqid=-1; if((msqid=msgget(key,IPC_CREAT|0664))==-1){ perror("msgget error"); return -1; } //创建一个子进程 pid_t pid=fork(); if(pid>0){ //父进程向消息队列中写入类型为1的消息正文 //定义一个消息 struct msgbuf sbuf; sbuf.mtype=1; while(1) { //清空容器 bzero(sbuf.mtest,sizeof(sbuf.mtest)); printf("发送的消息:"); fgets(sbuf.mtest,sizeof(sbuf.mtest),stdin); sbuf.mtest[strlen(sbuf.mtest)-1]='\0'; //将消息存放到消息队列 msgsnd(msqid,&sbuf,MSGSIZE,0); printf("发送成功\n"); if(strcmp(sbuf.mtest,"quit")==0){ break; } } wait(NULL); }else if(pid==0){ //子进程从消息队列中取出类型为2的消息正文 //定义一个消息 struct msgbuf rbuf; while(1) { //清空容器 bzero(rbuf.mtest,sizeof(rbuf.mtest)); //从消息队列中读取类型为2的消息正文 msgrcv(msqid,&rbuf,MSGSIZE,2,0); printf("收到的消息为:%s\n",rbuf.mtest); if(strcmp(rbuf.mtest,"quit")==0){ break; } } exit(EXIT_SUCCESS); }else{ perror("fork error"); return -1; } return 0; }msgrcv.c:
#include <myhead.h> //定义一个消息类型 struct msgbuf { long mtype; char mtest[1024]; }; //宏表示消息正文大小 #define MSGSIZE sizeof(struct msgbuf)-sizeof(long) /*****************************主程序***********************/ int main(int argc, const char *argv[]) { //1、创建key值 key_t key=0; if((key=ftok("/",'k'))==-1){ perror("ftok error"); return -1; } //根据key值创建一个消息队列 int msqid=-1; if((msqid=msgget(key,IPC_CREAT|0664))==-1){ perror("msgget error"); return -1; } //创建一个子进程 pid_t pid=fork(); if(pid>0){ //父进程从消息队列中取出类型为1的消息正文 //定义一个消息 struct msgbuf rbuf; while(1) { //清空容器 bzero(rbuf.mtest,sizeof(rbuf.mtest)); //从消息队列中读取类型为1的消息正文 msgrcv(msqid,&rbuf,MSGSIZE,1,0); printf("收到的消息为:%s\n",rbuf.mtest); if(strcmp(rbuf.mtest,"quit")==0){ break; } } wait(NULL); }else if(pid==0){ //子进程向消息队列中写入类型为2的消息正文 //定义一个消息 struct msgbuf sbuf; sbuf.mtype=2; while(1) { //清空容器 bzero(sbuf.mtest,sizeof(sbuf.mtest)); printf("发送的消息:"); fgets(sbuf.mtest,sizeof(sbuf.mtest),stdin); sbuf.mtest[strlen(sbuf.mtest)-1]='\0'; //将消息存放到消息队列 msgsnd(msqid,&sbuf,MSGSIZE,0); printf("发送成功\n"); if(strcmp(sbuf.mtest,"quit")==0){ break; } } exit(EXIT_SUCCESS); }else{ perror("fork error"); return -1; } return 0; }