资深程序员：深入Python进程间通信原理！

概述<pstyle=\"margin-top:16px;color:rgb(34,34,34);font-family:\'PingFangSC\',\'HiraginoSansGB\',\'MicrosoftYaHei\',\'WenQuanYiMicroHei\',\'HelveticaNeue\',Arial,sans-serif;background-color:rgb(255

<p >

<p >

<p >

<p >输出

<pre >3.14159262176<p >管道pipe

<p >管道是Unix进程间通信最常用的方法之一，它通过在父子进程之间开通读写通道来进行双工交流。我们通过os.read()和os.write()来对文件描述符进行读写 *** 作，使用os.close()关闭描述符。

<p >

<p >上图为单进程的管道

<p >

<p >上图为父子进程分离后的管道

<p >

<p >无名套接字socketpair

<p >我们知道跨网络通信免不了要通过套接字进行通信，但是本例的多进程是在同一个机器上，用不着跨网络，使用普通套接字进行通信有点浪费。

<p >

<p >上图为单进程的socketpair

<p >

<p >

<p >

<p >OS消息队列

<p > *** 作系统也提供了跨进程的消息队列对象可以让我们直接使用，只不过python没有默认提供包装好的API来直接使用。我们必须使用第三方扩展来完成OS消息队列通信。第三方扩展是通过使用Python包装的C实现来完成的。

<p >

<p >

<p >

<p >systemv消息队列systemv消息队列和posix消息队列用起来有所不同。systemv的消息队列是以整数key作为名称，如果不指定，它就创建一个唯一的未占用的整数key。它还提供消息类型的整数参数，但是不支持消息优先级。

<p >

<p >

<p >

<pre ># coding: utf-8import osimport sysimport mathimport structimport posix_ipcfrom posix_ipc import Semaphorefrom posix_ipc import SharedMemory as Memorydef slice(mink,maxk):s = 0.0for k in range(mink,maxk):s += 1.0/(2k+1)/(2k+1) return sdef pi(n):pids = []unit = n / 10sem_lock = Semaphore("/pi_sem_lock",flags=posix_ipc.O_CREX,initial_value=1) # 使用一个信号量控制多个进程互斥访问共享内存memory = Memory("/pi_rw",size=8,flags=posix_ipc.O_CREX)os.lseek(memory.fd,os.SEEK_SET) # 初始化和为0.0的double值os.write(memory.fd,struct.pack('d',0.0)) for i in range(10): # 分10个子进程mink = unit imaxk = mink + unitpid = os.fork() if pid > 0:pIDs.append(pID) else:s = slice(mink,maxk) # 子进程开始计算sem_lock.acquire() try:os.lseek(memory.fd,os.SEEK_SET)bs = os.read(memory.fd,8) # 从共享内存读出来当前值cur_val,= struct.unpack('d',bs) # 反序列化，逗号不能少cur_val += s # 加上当前进程的计算结果bs = struct.pack('d',cur_val) # 序列化os.lseek(memory.fd,os.SEEK_SET)os.write(memory.fd,bs) # 写进共享内存memory.close_fd() finally:sem_lock.release()sys.exit(0) # 子进程结束sums = [] for pID in pIDs:os.waitpID(pID,0) # 等待子进程结束os.lseek(memory.fd,8) # 读出最终这结果sums,bs) # 反序列化memory.close_fd() # 关闭共享内存memory.unlink() # 销毁共享内存sem_lock.unlink() # 销毁信号量return math.sqrt(sums 8)print pi(10000000)<p >欢迎关注我的博客园和公众号：https://home.cnblogs.com/u/Python1234/ Python学习交流

<p >欢迎加入我的千人交流答疑群：125240963

总结

以上是内存溢出为你收集整理的资深程序员：深入Python进程间通信原理！全部内容，希望文章能够帮你解决资深程序员：深入Python进程间通信原理！所遇到的程序开发问题。

如果觉得内存溢出网站内容还不错，欢迎将内存溢出网站推荐给程序员好友。