国产探花免费观看_亚洲丰满少妇自慰呻吟_97日韩有码在线_资源在线日韩欧美_一区二区精品毛片,辰东完美世界有声小说,欢乐颂第一季,yy玄幻小说排行榜完本

首頁 > 編程 > Python > 正文

Python multiprocessing模塊中的Pipe管道使用實例

2020-02-23 00:39:50
字體:
來源:轉載
供稿:網友

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

發表評論 共有條評論
用戶名: 密碼:
驗證碼: 匿名發表
主站蜘蛛池模板: 晋城| 大渡口区| 祥云县| 和顺县| 凌云县| 弥勒县| 桐城市| 嘉祥县| 静海县| 绥阳县| 芜湖市| 天峨县| 郴州市| 射洪县| 龙陵县| 历史| 渭源县| 阳朔县| 榕江县| 翁牛特旗| 岳西县| 文山县| 昌江| 湘乡市| 荃湾区| 社旗县| 离岛区| 抚远县| 浠水县| 玉田县| 姜堰市| 永丰县| 遂平县| 赤水市| 嘉定区| 石家庄市| 夏邑县| 红原县| 泸州市| 游戏| 巴彦淖尔市|