深圳行业网站建设,成都 建设网站,wordpress开发文档,西双版纳傣族自治州属于哪个市进程间通信机制(IPC)
简述
IPC#xff1a;Inter Process Communication
进程和进程之间的用户空间相互独立#xff0c;但是4G内核空间共享#xff0c;进程间的通信就是通过这4G的内核空间
分类
传统的进程间通信机制
无名管道#xff08;pipe#xff09;
有名管道Inter Process Communication
进程和进程之间的用户空间相互独立但是4G内核空间共享进程间的通信就是通过这4G的内核空间
分类
传统的进程间通信机制
无名管道pipe
有名管道fifo
信号signal
System V中的IPC对象和IPC的区别
消息队列message queue
共享内存shared memory
信号灯集semaphore
可用于主机传输的通信机制
套接字socket 消息队列
概念
在内核内存中创建一个队列进程需要将数据打包成结点添加到队尾中或者从队列中读取结点可以通过消息类型进行消息分类
特点
需要打包有特定的格式以及消息类型
按照先进先出原则但是也可以限制消息类型读取
独立于进程灯进程结束后消息队列以及其中的内容不会删除除非中期操作系统或者手动删除
在Linux系统下可以通过命令ipcs查看消息队列通过ipcrm -q msqid删除消息队列
函数
ftok()函数获得一个Key值用来创建消息队列通过相同的key值可以访问对应的消息队列
msgget()函数创建一个消息队列获得起id号
msgsnd()发送消息到指定消息队列
msgrcv()获取对应消息队列中对应的消息
msgctl()控制消息队列常用于删除消息队列
#includemyhead.h
#includesys/msg.h
#includesys/ipc.h
struct msgbuf
{long mtype; //消息类型char mtext[128]; //消息内容
};//线程1函数
void *task1(void *arg)
{int msqid *(int *)arg;//获取消息队列id号struct msgbuf msbuf;//声明消息结构体printf(A\n\t);fflush(stdout);while (1){msbuf.mtype 1;//消息类型fgets(msbuf.mtext,sizeof(msbuf.mtext),stdin);msbuf.mtext[strlen(msbuf.mtext)-1]\0;if(msgsnd(msqid,msbuf,sizeof(msbuf)-sizeof(long),0) -1){perror(msgsnd);return NULL;}//printf(线程%d:发送成功\n,getpid());printf(A\n\t);fflush(stdout);if (!strcmp(msbuf.mtext,quit)){system(clear);exit(0);}}pthread_exit(NULL);
}//线程2函数
void *task2(void *arg)
{int msqid *(int *)arg;struct msgbuf buf;ssize_t num 0;while (1){bzero(buf,sizeof(buf));if ((num msgrcv(msqid,buf,sizeof(buf.mtext),2,0))0){//perror(msgrcv);return NULL;}printf(\nB\n\t%s\n,buf.mtext);printf(A\n\t);fflush(stdout);if (!strcmp(buf.mtext,quit)){msgctl(msqid,IPC_RMID,NULL);system(clear);exit(0);}}pthread_exit(NULL);
}
int main(int argc, const char *argv[])
{key_t key ftok(./,0);if (key -1){perror(ftok);return -1;/* code */}umask(0);int msqid msgget(key,IPC_CREAT|0664);if (msqid -1){perror(msgget);return -1;}pthread_t tid1,tid2;if (pthread_create(tid1,NULL,task1,msqid) ! 0){printf(线程1创建失败\n);}if (pthread_create(tid2,NULL,task2,msqid) ! 0){printf(线程1创建失败\n);}pthread_join(tid1,NULL);pthread_join(tid2,NULL);return 0;
}#includemyhead.h
//#includesys/msg.h
//#includesys/ipc.h
struct msgbuf
{long mtype; //消息类型char mtext[128]; //消息内容
};//线程1函数
void *task1(void *arg)
{int msqid *(int *)arg;struct msgbuf msbuf;printf(B\n\t);fflush(stdout);while (1){msbuf.mtype 2;fgets(msbuf.mtext,sizeof(msbuf.mtext),stdin);msbuf.mtext[strlen(msbuf.mtext)-1]\0;if(msgsnd(msqid,msbuf,sizeof(msbuf)-sizeof(long),0) -1){perror(msgsnd);return NULL;}//printf(线程%d:发送成功\n,getpid());printf(B\n\t);fflush(stdout);if (!strcmp(msbuf.mtext,quit)){system(clear);exit(0);}}pthread_exit(NULL);
}//线程2函数
void *task2(void *arg)
{int msqid *(int *)arg;struct msgbuf buf;ssize_t num 0;while (1){bzero(buf,sizeof(buf));if ((num msgrcv(msqid,buf,sizeof(buf.mtext),1,0))0){//perror(msgrcv);return NULL;}printf(\nA\n\t%s\n,buf.mtext);printf(B\n\t);fflush(stdout);if (!strcmp(buf.mtext,quit)){msgctl(msqid,IPC_RMID,NULL);system(clear);exit(0);}}pthread_exit(NULL);
}
int main(int argc, const char *argv[])
{key_t key ftok(./,0);if (key -1){perror(ftok);return -1;/* code */}umask(0);int msqid msgget(key,IPC_CREAT|0664);if (msqid -1){perror(msgget);return -1;}pthread_t tid1,tid2;if (pthread_create(tid1,NULL,task1,msqid) ! 0){printf(线程1创建失败\n);}if (pthread_create(tid2,NULL,task2,msqid) ! 0){printf(线程1创建失败\n);}pthread_join(tid1,NULL);pthread_join(tid2,NULL);return 0;
}
