python调用pipe_Python multiprocessing模块中的Pipe管道使用实例

multiprocessing.Pipe([duplex])

返回2个连接对象(conn1, conn2),代表管道的两端,默认是双向通信.如果duplex=False,conn1只能用来接收消息,conn2只能用来发送消息.不同于os.open之处在于os.pipe()返回2个文件描述符(r, w),表示可读的和可写的

实例如下:

代码如下:

#!/usr/bin/python

#coding=utf-8

import os

from multiprocessing import Process, Pipe

def send(pipe):

pipe.send([‘spam’] + [42, ‘egg’])

pipe.close()

def talk(pipe):

pipe.send(dict(name = ‘Bob’, spam = 42))

reply = pipe.recv()

print(‘talker got:’, reply)

if __name__ == ‘__main__’:

(con1, con2) = Pipe()

sender = Process(target = send, name = ‘send’, args = (con1, ))

sender.start()

print “con2 got: %s” % con2.recv()#从send收到消息

con2.close()

(parentEnd, childEnd) = Pipe()

child = Process(target = talk, name = ‘talk’, args = (childEnd,))

child.start()

print(‘parent got:’, parentEnd.recv())

parentEnd.send({x * 2 for x in ‘spam’})

child.join()

print(‘parent exit’)

输出如下:

代码如下:

con2 got: [‘spam’, 42, ‘egg’]

(‘parent got:’, {‘name’: ‘Bob’, ‘spam’: 42})

(‘talker got:’, set([‘ss’, ‘aa’, ‘pp’, ‘mm’]))

parent exit

python调用pipe_Python multiprocessing模块中的Pipe管道使用实例相关推荐

python管道pipe_Python multiprocessing模块中的Pipe管道
multiprocessing.Pipe([duplex]) 返回2个连接对象(conn1, conn2),代表管道的两端,默认是双向通信.如果duplex=False,conn1只能用来接收消息,c ...
在.NET程序中使用PIPE(管道技术)
在.NET程序中使用PIPE(管道技术) 这几天不知道做什么, 受朋友影响, 看完了"新天龙八部", 深受感动, 所以打算做点好事. =) 关于PIPE的应用, 其实原理很简单, ...
《Python编程从入门到实践》记录之将Python函数存储在模块中（import、import*）
目录 1.导入整个模块 2.导入特定的函数 3.使用as给函数指定别名 4.导入模块中的所有函数 5.总结我们可以在编写程序时将函数存储在被称为模块的独立文件中,再将模块导入到主程序中(必须的步骤) ...
Python笔记（二）——python调用C/C++模块
前一篇讲了简单的C/C++调用Python脚本模块(.py).既然是用于诸多游戏程序的脚本语言,那肯定是缺不了互调(礼尚往来).因此,本篇讲一个简单的python调用C/C++写的DLL模块,对Pyt ...
python iloc函数_如何使用python语言中pandas模块中的iloc方法
在python语言中,pandas模块中的iloc方法,可以截取矩阵,获取部分矩阵元素.行和列.下面利用实例说明iloc方法的用法,操作如下: 工具/原料 python pycharm 截图工具方法 ...
Python内置time模块中，time.time()函数和time.sleep()函数的用法
time模块 time模块是Python内置模块,能让Python程序读取系统时钟的当前使时间.在time模块中,time.time( ) 和time.sleep( )函数是最常用和最有用的模块. t ...
python multiprocessing_Python的multiprocessing模块详解
通过multiprocessing模块的Process类创建一个进程的实力,并通过run()的方法来运行他from multiprocessing import Process import os d ...
Linux中的pipe(管道)与named pipe(FIFO 命名管道)
catalogue 1. pipe匿名管道 2. named pipe(FIFO)有名管道 1. pipe匿名管道管道是Linux中很重要的一种通信方式,是把一个程序的输出直接连接到另一个程序的输入 ...
php中调用go代码,php中的goto的用法实例（代码）
本篇文章给大家带来的内容是关于php中的goto的用法实例(代码),有一定的参考价值,有需要的朋友可以参考一下,希望对你有所帮助. 我们先举个简单示例: goto LABEL; //这个标签自定义ec ...

python调用pipe_Python multiprocessing模块中的Pipe管道使用实例

python调用pipe_Python multiprocessing模块中的Pipe管道使用实例相关推荐

最新文章

热门文章