最新国产好看的视频,伊人天堂AV在线,国产Aaaaaa视频,蜜臀视频在线观看一区,人妻av色图,密臀久久久精品影片,青青视频免费观看毛片,久草在线观看视,国产三级精品色情在线

Python multiprocessing模塊中的Pipe管道使用實(shí)例

 更新時(shí)間:2015年04月11日 11:30:21   投稿:junjie  
這篇文章主要介紹了Python multiprocessing模塊中的Pipe管道使用實(shí)例,本文直接給出使用實(shí)例,需要的朋友可以參考下

multiprocessing.Pipe([duplex])
返回2個(gè)連接對(duì)象(conn1, conn2),代表管道的兩端,默認(rèn)是雙向通信.如果duplex=False,conn1只能用來接收消息,conn2只能用來發(fā)送消息.不同于os.open之處在于os.pipe()返回2個(gè)文件描述符(r, w),表示可讀的和可寫的

實(shí)例如下:

復(fù)制代碼 代碼如下:

#!/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')

輸出如下:

復(fù)制代碼 代碼如下:

con2 got: ['spam', 42, 'egg']
('parent got:', {'name': 'Bob', 'spam': 42})
('talker got:', set(['ss', 'aa', 'pp', 'mm']))
parent exit

相關(guān)文章

最新評(píng)論

清新县| 清远市| 张掖市| 扎赉特旗| 高密市| 通渭县| 武定县| 靖安县| 道真| 南投市| 菏泽市| 余江县| 泸定县| 安义县| 多伦县| 中卫市| 延边| 东兰县| 镇康县| 屯门区| 前郭尔| 凤阳县| 赣榆县| 辽宁省| 黄陵县| 庆云县| 长兴县| 丁青县| 克拉玛依市| 德保县| 佳木斯市| 卢龙县| 宣恩县| 寿宁县| 永康市| 天柱县| 麻江县| 新疆| 安龙县| 仪征市| 乡城县|