当前位置: 首页>资讯 >

天天通讯!多进程编程知识汇总(附代码例子)

来源: 面包芯语 | 时间: 2023-06-15 12:20:48 |

一、什么是进程?

1、进程和线程的区别

#include#includeintmain(void){system("ls");printf("lsend\n");return0;}

(2)通过fork函数启动进程。(用于启动子进程)

#include#include/***@brieffork系统调用用于创建一个子进程**Detailedfunctiondescription**@param[in]**@return 如果发生错误,则返回值为-1,否则返回命令的状态。*/pid_tfork(void);
#include#include#include#includeintmain(void){pid_tres=fork();///<子进程if(res==0){printf("res=%d,Iamchildprocess.pid=%d\n",res,getpid());exit(EXIT_SUCCESS);///<正常退出子进程}///<父进程elseif(res>0){printf("res=%d,Iamparentprocess.pid=%d\n",res,getpid());intchild_status=0;pid_tchild_pid=wait(&child_status);///<父进程阻塞等待信号到来或子进程结束printf("Childprocess(pid=%d)hasbeenterminated,child_status=%d\n",child_pid,child_status);}///<异常退出else{printf("Forkfailed.\n");exit(EXIT_FAILURE);}return0;}

(3)通过exec系列函数启动进程。(用于启动新进程,新进程会覆盖旧进程)

#include/***@brief启动新进程,新进程会覆盖旧进程**Detailedfunctiondescription**@param[in]path:所执行文件的路径*@param[in]file:所执行文件的名称*@param[in]arg:传入的参数列表,以NULL作为结束*@param[in]envp:传入的环境变量**@return 如果发生错误,则返回值为-1,否则返回命令的状态。*/intexecl(constchar*path,constchar*arg,...);intexeclp(constchar*file,constchar*arg,...);intexecle(constchar*path,constchar*arg,...,char*constenvp[]);intexecv(constchar*path,char*constargv[]);intexecvp(constchar*file,char*constargv[]);intexecve(constchar*path,char*constargv[],char*constenvp[]);
#include#includeintmain(void){execl("/bin/ls","ls","-la",NULL);printf("lsend\n");return0;}

在Linux中终止一个进程有多种方法:

二、进程间通信方式

进程间通信是指在不同进程之间传播或交换信息的一种机制。每个进程各自有不同的用户地址空间,任何一个进程的全局变量在另一个进程中都看不到,所以进程之间要交换数据必须通过内核,在内核中开辟一块缓冲区,进程A把数据从用户空间拷到内核缓冲区,进程B再从内核缓冲区把数据读走,内核提供的这种机制称为进程间通信。


(资料图)

进程间通信的目的:

Linux IPC(Inter-process Comminication, 进程间通信)的方式:

1、消息队列

内核中的一个优先级队列,多个进程通过访问同一个队列,进行添加结点或者获取结点实现通信。

POSIX消息队列头文件:

#include/*ForO_*constants*/#include/*Formodeconstants*/#include

编译链接需要加上 -lrt链接。

消息队列API接口:

/***@brief创建消息队列实例**Detailedfunctiondescription**@param[in]name:消息队列名称*@param[in] oflag:根据传入标识来创建或者打开一个已创建的消息队列-O_CREAT:创建一个消息队列-O_EXCL:检查消息队列是否存在,一般与O_CREAT一起使用-O_CREAT|O_EXCL:消息队列不存在则创建,已存在返回NULL-O_NONBLOCK:非阻塞模式打开,消息队列不存在返回NULL-O_RDONLY:只读模式打开-O_WRONLY:只写模式打开-O_RDWR:读写模式打开*@param[in] mode:访问权限*@param[in] attr:消息队列属性地址**@return成功返回消息队列描述符,失败返回-1,错误码存于error中*/mqd_tmq_open(constchar*name,intoflag,mode_tmode,structmq_attr*attr);/***@brief无限阻塞方式接收消息**Detailedfunctiondescription**@param[in]mqdes:消息队列描述符*@param[in] msg_ptr:消息体缓冲区地址*@param[in] msg_len:消息体长度,长度必须大于等于消息属性设定的最大值*@param[in] msg_prio:消息优先级**@return成功返回消息长度,失败返回-1,错误码存于error中*/mqd_tmq_receive(mqd_tmqdes,char*msg_ptr,size_tmsg_len,unsigned*msg_prio);/***@brief指定超时时间阻塞方式接收消息**Detailedfunctiondescription**@param[in]mqdes:消息队列描述符*@param[in] msg_ptr:消息体缓冲区地址*@param[in] msg_len:消息体长度,长度必须大于等于消息属性设定的最大值*@param[in] msg_prio:消息优先级*@param[in] abs_timeout:超时时间**@return成功返回消息长度,失败返回-1,错误码存于error中*/mqd_tmq_timedreceive(mqd_tmqdes,char*msg_ptr,size_tmsg_len,unsigned*msg_prio,conststructtimespec*abs_timeout);/***@brief无限阻塞方式发送消息**Detailedfunctiondescription**@param[in]mqdes:消息队列描述符*@param[in] msg_ptr:待发送消息体缓冲区地址*@param[in] msg_len:消息体长度*@param[in] msg_prio:消息优先级**@return成功返回0,失败返回-1*/mqd_tmq_send(mqd_tmqdes,constchar*msg_ptr,size_tmsg_len,unsignedmsg_prio);/***@brief指定超时时间阻塞方式发送消息**Detailedfunctiondescription**@param[in]mqdes:消息队列描述符*@param[in] msg_ptr:待发送消息体缓冲区地址*@param[in] msg_len:消息体长度*@param[in] msg_prio:消息优先级*@param[in] abs_timeout:超时时间**@return成功返回0,失败返回-1*/mqd_tmq_timedsend(mqd_tmqdes,constchar*msg_ptr,size_tmsg_len,unsignedmsg_prio,conststructtimespec*abs_timeout);/***@brief关闭消息队列**Detailedfunctiondescription**@param[in]mqdes:消息队列描述符**@return成功返回0,失败返回-1*/mqd_tmq_close(mqd_tmqdes);/***@brief分离消息队列**Detailedfunctiondescription**@param[in]name:消息队列名称**@return成功返回0,失败返回-1*/mqd_tmq_unlink(constchar*name);

send.c:

#include#include#include#include#include/*ForO_*constants*/#include/*Formodeconstants*/#include#defineMQ_MSG_MAX_SIZE512///<最大消息长度#defineMQ_MSG_MAX_ITEM5///<最大消息数目staticmqd_ts_mq;typedefstruct_msg_data{charbuf[128];intcnt;}msg_data_t;voidsend_data(void){staticintcnt=0;msg_data_tsend_data={0};cnt++;strcpy(send_data.buf,"hello");send_data.cnt=cnt;intret=mq_send(s_mq,(char*)&send_data,sizeof(send_data),0);if(ret<0){perror("mq_senderror");return;}printf("sendmsg=%s,cnt=%d\n",send_data.buf,send_data.cnt);}intmain(void){intret=0;structmq_attrattr;///<创建消息队列memset(&attr,0,sizeof(attr));attr.mq_maxmsg=MQ_MSG_MAX_ITEM;attr.mq_msgsize=MQ_MSG_MAX_SIZE;attr.mq_flags=0;s_mq=mq_open("/mq",O_CREAT|O_RDWR,0777,&attr);if(-1==s_mq){perror("mq_openerror");return-1;}for(size_ti=0;i<10;i++){send_data();sleep(1);}mq_close(s_mq);return0;}
#include#include#include#include#include/*ForO_*constants*/#include/*Formodeconstants*/#include#defineMQ_MSG_MAX_SIZE512///<最大消息长度#defineMQ_MSG_MAX_ITEM5///<最大消息数目staticmqd_ts_mq;typedefstruct_msg_data{charbuf[128];intcnt;}msg_data_t;intmain(void){intret=0;structmq_attrattr;charrecv_msg[MQ_MSG_MAX_SIZE]={0};msg_data_trecv_data={0};intprio=0;ssize_tlen=0;s_mq=mq_open("/mq",O_RDONLY);if(-1==s_mq){perror("mq_openerror");return-1;}while(1){if((len=mq_receive(s_mq,(char*)&recv_data,MQ_MSG_MAX_SIZE,&prio))==-1){perror("mq_receiveerror");return-1;}printf("recv_msg=%s,cnt=%d\n",recv_data.buf,recv_data.cnt);sleep(1);}mq_close(s_mq);mq_unlink("/mq");return0;}
gccsend.c-osend_process-lrtgccrecv.c-orecv_process-lrt

2、共享内存

消息队列的读取和写入的过程,会有发生用户态与内核态之间的消息拷贝过程。而共享内存的方式则没有这个拷贝过程,进程间通信速度较快。

在物理内存上开辟一块内存空间,多个进程可以将同一块物理内存空间映射到自己的虚拟地址空间,通过自己的虚拟地址直接访问这块空间,通过这种方式实现数据共享。

#include#include#include
/***@brief创建共享内存实例**Detailedfunctiondescription**@param[in]name:要打开或创建的共享内存文件名*@param[in] oflag:打开的文件操作属性-O_CREAT:创建一个共享内存文件-O_EXCL:检查共享内存是否存在,一般与O_CREAT一起使用-O_CREAT|O_EXCL:共享内存不存在则创建,已存在返回NULL-O_NONBLOCK:非阻塞模式打开,共享内存不存在返回NULL-O_RDONLY:只读模式打开-O_WRONLY:只写模式打开-O_RDWR:读写模式打开*@param[in] mode:文件共享模式,例如0777**@return成功返回共享内存描述符,失败返回-1,错误码存于error中*/intshm_open(constchar*name,intoflag,mode_tmode);/***@brief删除共享内存**Detailedfunctiondescription**@param[in]name:创建的共享内存文件名**@return成功返回0,失败返回-1*/intshm_unlink(constchar*name);/***@brief将打开的文件映射到内存**Detailedfunctiondescription**@param[in]addr:要将文件映射到的内存地址,一般应该传递NULL来由Linux内核指定*@param[in]length:要映射的文件数据长度*@param[in]prot:映射的内存区域的操作权限(保护属性),包括PROT_READ、PROT_WRITE、PROT_READ|PROT_WRITE*@param[in] flags:标志位参数,包括:MAP_SHARED、MAP_PRIVATE与MAP_ANONYMOUS。*@param[in]fd:用来建立映射区的文件描述符,用shm_open打开或者open打开的文件*@param[in]offset:映射文件相对于文件头的偏移位置,应该按4096字节对齐**@return成功返回0,失败返回-1*/void*mmap(void*addr,size_tlength,intprot,intflags,intfd,off_toffset);/***@brief取消内存映射**Detailedfunctiondescription**@param[in]addr:由mmap成功返回的地址*@param[in]length:要取消的内存长度**@return成功返回0,失败返回-1*/intmunmap(void*addr,size_tlength);/***@brief将参数fd指定的文件大小改为参数length指定的大小**Detailedfunctiondescription**@param[in]fd:已打开的文件描述符,以写入模式打开的文件*@param[in]length:要设置的长度**@return成功返回0,失败返回-1*/intftruncate(intfd,off_tlength);/***@brief获取文件相关的信息,将获取到的信息放入到statbuf结构体中**Detailedfunctiondescription**@param[in]fd:已打开的文件描述符*@param[out]statbuf:文件的信息**@return成功返回0,失败返回-1*/intfstat(intfd,structstat*statbuf);

send.c:

#include#include#include#include#include/*ForO_*constants*/#include/*Formodeconstants*/#include#defineSHM_NAME"/shm"intmain(void){intret=0;///<创建和读端相同的文件标识intshm_fd=shm_open(SHM_NAME,O_RDWR|O_CREAT,0666);if(shm_fd==-1){printf("shm_openerror\n");}///<设置共享内存文件为8KBftruncate(shm_fd,8*1024);///<获取共享内存文件相关属性信息structstatfilestat={0};fstat(shm_fd,&filestat);printf("st_size=%ld\n",filestat.st_size);///<内存映射char*shm_ptr=(char*)mmap(NULL,filestat.st_size,PROT_READ|PROT_WRITE,MAP_SHARED,shm_fd,0);close(shm_fd);///<向共享内存中写入数据charbuf[]="helloworld";memmove(shm_ptr,buf,sizeof(buf));printf("pid%d,%s\n",getpid(),shm_ptr);///<写入完成后解除映射munmap(shm_ptr,filestat.st_size);return0;}
#include#include#include#include#include/*ForO_*constants*/#include/*Formodeconstants*/#include#defineSHM_NAME"/shm"intmain(void){///<创建共享内存文件标识符intshm_fd=shm_open(SHM_NAME,O_RDWR|O_CREAT,0666);if(shm_fd==-1){printf("shm_openfailed\n");exit(EXIT_FAILURE);}///<设置共享内存文件为8KBftruncate(shm_fd,8192);///<获取共享内存文件相关属性信息structstatfilestat;fstat(shm_fd,&filestat);printf("st_size=%ld\n",filestat.st_size);///<映射共享内存,并获取共享内存的地址char*shm_ptr=(char*)mmap(NULL,filestat.st_size,PROT_READ|PROT_WRITE,MAP_SHARED,shm_fd,0);close(shm_fd);///<获取共享内存地址中的内容并打印,最后再解除映射,删除共享内存printf("pid=%d,%s\n",getpid(),shm_ptr);munmap(shm_ptr,filestat.st_size);shm_unlink(SHM_NAME);return0;}
gccsend.c-osend_process-lrtgccrecv.c-orecv_process-lrt

对具有多个处理核系统消息传递的性能要优于共享内存。共享内存会有高速缓存一致性问题,这是由共享数据在多个高速缓存之间迁移而引起的。随着系统的处理核的数量的日益增加,可能导致消息传递作为 IPC 的首选机制。

3、socket

UNIX域套接字与传统基于TCP/IP协议栈的socket不同,unix domain socket以文件系统作为地址空间,不需经过TCP/IP的头部封装、报文ack确认、路由选择、数据校验与重传过程,因此传输速率上也不会受网卡带宽的限制。

unix domain socket在进程间通信同样是基于“客户端—服务器”(C-S)模式。

UNIX域套接字基本API接口使用例子:基于UNIX域套接字客户端进程向服务端进程发送测试数据。

server.c:

#include#include#include#include#include/*ForO_*constants*/#include/*Formodeconstants*/#include#include#include#include#defineSERVER_PATH"/tmp/server"intmain(void){///<创建UNIX域字节流套接字intserver_fd=socket(AF_LOCAL,SOCK_STREAM,0);if(server_fd<0){printf("socketerror\n");exit(EXIT_FAILURE);}///<绑定服务端地址unlink(SERVER_PATH);structsockaddr_unserver_addr;memset((char*)&server_addr,0,sizeof(server_addr));server_addr.sun_family=AF_LOCAL;strncpy(server_addr.sun_path,SERVER_PATH,sizeof(server_addr.sun_path)-1);if(bind(server_fd,(structsockaddr*)&server_addr,sizeof(server_addr))<0){printf("binderror\n");close(server_fd);exit(EXIT_FAILURE);}///<监听if(listen(server_fd,10)<0){printf("listenerror\n");close(server_fd);exit(EXIT_FAILURE);}///<等待客户端连接intaddr_len=sizeof(structsockaddr);structsockaddr_unclient_addr;intclient_fd=accept(server_fd,(structsockaddr*)&client_addr,(socklen_t*)&addr_len);if(client_fd<0){printf("accepterror\n");close(server_fd);unlink(SERVER_PATH);exit(1);}else{printf("connectedclient:%s\n",client_addr.sun_path);}while(1){charbuf[128]={0};intrecv_len=read(client_fd,buf,sizeof(buf));if(recv_len<=0){printf("recverror!\n");close(client_fd);exit(EXIT_FAILURE);}printf("recv:%s\n",buf);}unlink(SERVER_PATH);close(server_fd);close(client_fd);return0;}
#include#include#include#include#include/*ForO_*constants*/#include/*Formodeconstants*/#include#include#include#include#defineSERVER_PATH"/tmp/server"#defineCLIENT_PATH"/tmp/client"intmain(void){///<创建UNIX域字节流套接字intclient_fd=socket(AF_UNIX,SOCK_STREAM,0);if(client_fd<0){printf("socketerror\n");exit(EXIT_FAILURE);}///<显式绑定客户端地址structsockaddr_unclient_addr;memset((char*)&client_addr,0,sizeof(client_addr));client_addr.sun_family=AF_UNIX;strncpy(client_addr.sun_path,CLIENT_PATH,sizeof(client_addr.sun_path)-1);unlink(CLIENT_PATH);if(bind(client_fd,(structsockaddr*)&client_addr,sizeof(client_addr))<0){printf("binderror\n");close(client_fd);exit(1);}///<连接服务端structsockaddr_unserver_addr;server_addr.sun_family=AF_UNIX;strncpy(server_addr.sun_path,SERVER_PATH,sizeof(server_addr.sun_path)-1);intret=connect(client_fd,(structsockaddr*)&server_addr,sizeof(server_addr));if(ret<0){printf("connecterror\n");close(client_fd);unlink(CLIENT_PATH);exit(1);}printf("connecttoserver:%s\n",server_addr.sun_path);while(1){charbuf[128]={0};if(scanf("%s",buf)){intsend_len=write(client_fd,buf,strlen(buf));if(send_len<=0){printf("writeerror!\n");close(client_fd);exit(EXIT_FAILURE);}else{printf("sendsuccess!send:%s,send_len:%d\n",buf,send_len);}}}unlink(SERVER_PATH);close(client_fd);return0;}

编译、运行:

gccserver.c-oserver_processgccclient.c-oclient_process

类socket的其它进程间通信方式:

实用 | nanomsg通信库的简单使用分享

mqtt应用于进程间通信

4、管道

在内核中开辟一块缓冲区;若多个进程拿到同一个管道(缓冲区)的操作句柄,就可以访问同一个缓冲区,就可以进行通信。涉及到两次用户态与内核态之间的数据拷贝。

(1)匿名管道

内核中的缓冲区是没有具体的标识符的,匿名管道只能用于具有亲缘关系的进程间通信。

管道是一个半双工通信(可以选择方向的单向传输)

匿名管道基本API接口使用例子:父进程通过管道发送测试数据给子进程。

#include#include#include#includeintmain(){///<创建管道intpipefd[2]={-1};intret=pipe(pipefd);if(ret<0){printf("pipeerror\n");exit(EXIT_FAILURE);}intread_fd=pipefd[0];///0){///<父进程向管道写入数据char*ptr="hello88888888\n";write(write_fd,ptr,strlen(ptr));}return0;}

如果需要双向通信,则应该创建两个管道。

(2)命名管道

命名管道也是内核中的一块缓冲区,并且这个缓冲区具有标识符;这个标识符是一个可见于文件系统的管道文件,能够被其他进程找到并打开管道文件,则可以获取管道的操作句柄,所以该命名管道可用于同一主机上的任意进程间通信。

创建命名管道的接口:

intmkfifo(constchar*pathname,mode_tmode);

fifo_wr.c:

#include#include#include#include#include#include#include#defineFIFO_PATH"./fifo_file"typedefstruct_msg_data{charbuf[128];intcnt;}msg_data_t;voidsend_data(intfd){staticintcnt=0;msg_data_tsend_data={0};cnt++;strcpy(send_data.buf,"hello");send_data.cnt=cnt;write(fd,&send_data,sizeof(send_data));printf("sendmsg=%s,cnt=%d\n",send_data.buf,send_data.cnt);}intmain(void){///<创建管道文件intret=mkfifo(FIFO_PATH,0664);if(ret<0&&errno!=EEXIST){printf("mkfifoerror\n");exit(EXIT_FAILURE);}///<以只写的方式打开管道文件intfd=open(FIFO_PATH,O_WRONLY);if(fd<0){printf("openfifoerror\n");exit(EXIT_FAILURE);}printf("openfifosuccess\n");///<写10次for(size_ti=0;i<10;i++){send_data(fd);sleep(1);}close(fd);return0;}
#include#include#include#include#include#include#include#defineFIFO_PATH"./fifo_file"typedefstruct_msg_data{charbuf[128];intcnt;}msg_data_t;intmain(void){umask(0);///<创建管道文件intret=mkfifo(FIFO_PATH,0664);if(ret<0&&errno!=EEXIST){printf("mkfifoerror\n");exit(EXIT_FAILURE);}///<以只读方式获取管道文件的操作句柄intfd=open(FIFO_PATH,O_RDONLY);if(fd<0){printf("openerror\n");exit(EXIT_FAILURE);}printf("openfifosuccess\n");while(1){msg_data_tread_data={0};///<将从管道读取的文件写到buf中intret=read(fd,&read_data,sizeof(read_data));if(ret<0){printf("readerror\n");exit(EXIT_FAILURE);}elseif(ret==0){printf("allwriteclosed\nd");exit(EXIT_FAILURE);}printf("read_data=%s,cnt=%d\n",read_data.buf,read_data.cnt);sleep(1);}close(fd);return0;}
gccfifo_wr.c-ofifo_wrgccfifo_rd.c-ofifo_rd

5、信号量

信号量(Seamphore)是进程和线程间同步的一种机制。

信号量本质是一个非负的整型变量。增加一个可用资源执行加一,也称为V操作;获取一个资源资源后执行减一,也称为P操作。

信号量根据信号值不同可分为两类:

信号量根据作用对象不同可分为两类:

POSIX信号量头文件:

#include

编译链接需要加-lpthread参数。

信号量API接口:

/***@brief创建信号量**Detailedfunctiondescription**@param[in]name:信号量名称*@param[in]mode:访问权限*@param[in]value:信号量初始值**@return成功时返回指向信号量的指针,出错时为SEM_FAILED*/sem_t*sem_open(constchar*name,intoflag,mode_tmode,unsignedintvalue);/***@brief初始化信号量**Detailedfunctiondescription**@param[in]sem:信号量实例地址*@param[in]pshared:信号量作用域,分为进程内作用域PTHREAD_PROCESS_PRIVATE和跨进程作用域PTHREAD_PROCESS_SHARED*@param[in]value:信号量初始值**@return成功返回0,失败返回-1*/intsem_init(sem_t*sem,intpshared,unsignedintvalue);/***@brief获取信号量**Detailedfunctiondescription**@param[in]sem:信号量实例地址*@param[out]sval:保存返回信号值地址**@return成功返回0,失败返回-1*/intsem_getvalue(sem_t*sem,int*sval);/***@brief阻塞方式等待信号量**Detailedfunctiondescription**@param[in]sem:信号量实例地址**@return成功返回0,失败返回-1*/intsem_wait(sem_t*sem);/***@brief指定超时时间阻塞方式等待信号量**Detailedfunctiondescription**@param[in]sem:信号量实例地址*@param[in]sem:超时时间,单位为时钟节拍**@return成功返回0,失败返回-1*/intsem_timedwait(sem_t*sem,conststructtimespec*abs_timeout);/***@brief非阻塞方式等待信号量**Detailedfunctiondescription**@param[in]sem:信号量实例地址**@return成功返回0,失败返回-1*/intsem_trywait(sem_t*sem);/***@brief产生信号量**Detailedfunctiondescription**@param[in]sem:信号量实例地址**@return成功返回0,失败返回-1*/intsem_post(sem_t*sem);/***@brief销毁信号量**Detailedfunctiondescription**@param[in]sem:信号量实例地址**@return成功返回0,失败返回-1*/intsem_destroy(sem_t*sem);/***@brief关闭信号量**Detailedfunctiondescription**@param[in]sem:信号量实例地址**@return成功返回0,失败返回-1*/intsem_close(sem_t*sem);/***@brief分离信号量**Detailedfunctiondescription**@param[in]name:信号量名称**@return成功返回0,失败返回-1*/intsem_unlink(constchar*name);
#include#include#include#include#include#defineSEM_NAME"sem"intmain(void){intsem_val=0;///<创建信号量sem_t*sem=sem_open(SEM_NAME,O_CREAT,0666,1);if(NULL==sem){printf("sem_openerror\n");exit(EXIT_FAILURE);}///<创建子进程pid_tpid=fork();if(pid==-1){printf("forkerror\n");sem_close(sem);sem_unlink(SEM_NAME);exit(EXIT_FAILURE);}elseif(pid==0){///<子进程进行5次P操作for(size_ti=0;i<5;i++){sem_wait(sem);if(sem_getvalue(sem,&sem_val)!=-1){printf("childprocessPoperation,sem_val=%d\n",sem_val);sleep(1);}}_exit(1);}elseif(pid>0){///<父进程执行5次V操作for(size_ti=0;i<5;i++){sem_post(sem);if(sem_getvalue(sem,&sem_val)!=-1){printf("prarentprocessVoperation,sem_val=%d\n",sem_val);sleep(2);}}}///<删除sem信号量sem_close(sem);if(sem_unlink(SEM_NAME)!=-1){printf("sem_unlinksuccess\n");}return0;}

IPC总结:

操作系统根据不同的场景提供了不同的方式,消息队列、共享内存、UNIX域套接字、管道、信号量。

消息队列:内核中的一个优先级队列,多个进程通过访问同一个队列,在队列当中添加或者获取节点来实现进程间通信。

共享内存:本质是一块物理内存,多个进程将同一块物理内存映射到自己的虚拟地址空间中,再通过页表映射到物理地址达到进程间通信,它是最快的进程间通信方式,相较其他通信方式少了两步数据拷贝操作。

UNIX域套接字:与TCP/IP套接字使用方式相同,但UNIX域套接字以文件系统作为地址空间,不需经过TCP/IP的头部封装、报文ack确认、路由选择、数据校验与重传过程,因此传输速率上也不会受网卡带宽的限制。

管道:内核中的一块缓冲区,分为匿名管道和命名管道。匿名管道只能用于具有亲缘关系的进程间;而命名管道可用于同一主机上任意进程间通信。

信号量:本质是内核中的一个计数器,主要实现进程间的同步与互斥,对资源进行计数,有两种操作,分别是在访问资源之前进行的p操作,还有产生资源之后的v操作。

相关资料:

https://blog.51cto.com/u_13456560/5822959

关键词:

 

热文推荐

天天通讯!多进程编程知识汇总(附代码例子)

一、什么是进程?1、进程和线程的区别进程是指正在运行的程序,它拥有

2023-06-15

恭喜!香港知名女星挺大肚获男友惊喜求婚,未婚先孕六个多月

本文编辑剧透社:issac未经授权严禁转载,发现抄袭者将进行全网投诉恭

2023-06-15

晨会纪要_环球快报

晨会纪要

2023-06-15

天天新资讯:商业银行开辟绿色金融新赛道

党的二十大报告提出,完善支持绿色发展的财税、金融、投资、价格政策和

2023-06-15

世界热门:蚣组词大全_蚣怎组词

蚣bā蝮xià。蚣蝮:传说中龙生九子之一,性喜水,被雕成桥柱、建筑上

2023-06-15

【天天速看料】截至6月30日!大庆市医保政策临时调整

按照国家医保局和黑龙江省医保局有关全面推进基本医保全民参保工作部署

2023-06-15

港股开盘 | 恒指高开超1% 科网股走高 阿里巴巴-SW(09988)涨2.5%

恒指高开1 13%,恒生科技指数高开1 87%。科网股走高,阿里巴巴涨2 5%,

2023-06-15

【环球播资讯】【礼赞七十年·奋进新征程】沙拉村:团结一心奔小康

本报记者 高岳增太加夏日的贵南县芒曲镇沙拉村,村道两旁的紫丁香进入

2023-06-15

速递!佐力药业(300181.SZ):华东地区包含了中药饮片和配方颗粒的销售收入

格隆汇6月15日丨佐力药业300181300181SZ召开线上会议就公司华东地区销

2023-06-15

《披哥3》录制在即,9大重点嘉宾曝光,林志颖准C位,陈赫争议大

近几年的内娱综艺百花齐放,不少节目都自称是S+级制作,但真正能做到

2023-06-15

每日报道:张文彤强调 扛牢政治责任 守住安全底线

张文彤强调扛牢政治责任守住安全底线---湖北日报讯(记者刘胜)按照中

2023-06-15

今亮点!锁定面值退市的上市公司越来越多,“临时抱佛脚”自救还有效么?

锁定面值退市的上市公司越来越多,“临时抱佛脚”自救还有效么?

2023-06-15

热点在线丨这三大生肖6月份整体运势如何?进来接喜吧

属兔的朋友,心地善良,吉人自有天相,尽管现在的日子不是很富裕,但是

2023-06-15

三星音质好还是vivo好-世界简讯

这是一个星和vivo音质哪个更好的问题。虽然音质是一个相对主观的话题,

2023-06-15

来实况抽梅西!评论晒实况梅西视频或照片赢周边好礼-当前讯息

北京时间6月15日晚20:00,阿根廷将在北京工人体育场对阵澳大利亚。梅西

2023-06-15

黑龙江省鸡西市2023-06-10 05:46发布大雾黄色预警

一、黑龙江省鸡西市天气预报1、鸡东县气象台2023年6月10日05时20分发布

2023-06-14

世界最新:上海农商银行参展首届上海国际碳中和博览会

首届“上海国际碳中和技术、产品与成果博览会”于2023年6月11日至14日

2023-06-14

天天快看点丨启蒙 x 王者荣耀,积木人仔-经典款

大家好,今天由MAX带来的【虚测评】启蒙积木78001(王者荣耀积木人仔-

2023-06-14

倡议!寿光这些地方免费开放晒粮

关于免费开放村级活动场所为群众晒粮的倡议书寿光市村级党组织:麦收时

2023-06-14

大摩:特斯拉(TSLA.US)该全面推出汽车金融服务了_今日热文

摩根士丹利分析师AdamJonas表示特斯拉全面推出汽车金融服务的时候到了

2023-06-14