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

python 多進(jìn)程通信模塊的簡(jiǎn)單實(shí)現(xiàn)

 更新時(shí)間:2014年02月20日 15:35:38   作者:  
這篇文章主要介紹了python 多進(jìn)程通信模塊的簡(jiǎn)單實(shí)現(xiàn),需要的朋友可以參考下

多進(jìn)程通信方法好多,不一而數(shù)。剛才試python封裝好嘅多進(jìn)程通信模塊 multiprocessing.connection。

簡(jiǎn)單測(cè)試咗一下,效率還可以,應(yīng)該系對(duì)socket封裝,效率可以達(dá)到4krps,可以滿足好多方面嘅需求啦。

附代碼如下:

client

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

#!/usr/bin/python
# -*- coding: utf-8 -*-
""" download - slave
"""
__author__ = 'Zagfai'
__license__ = 'MIT@2014-02'

import webtul
from multiprocessing.connection import Client

a = 0
try:
    while True:
        a += 1
        address = ('10.33.41.112', 6666)
        conn = Client(address, authkey='hellokey')
        #print conn.recv()
        d = conn.recv()
        conn.close()
except:
    pass

print a

server

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

#!/usr/bin/python
# -*- coding: utf-8 -*-
""" downloader - master server
"""
__author__ = 'Zagfai'
__license__ = 'MIT@2014-02'

import webtul
from multiprocessing.connection import Listener
from threading import Thread


def listener():
    address = ('10.33.41.112', 6666)
    listener = Listener(address, backlog=100, authkey='hellokey')
    while True:
        conn = listener.accept()
        #print 'connection accepted from', listener.last_accepted
        try:
            conn.send({'1':2, '2':'abc'})
        except Exception, e:
            print e
        finally:
            conn.close()
    listener.close()

listener_th = Thread(target=listener)
listener_th.daemon = True
listener_th.start()
listener_th.join(timeout=20)

相關(guān)文章

最新評(píng)論

高雄县| 栾城县| 湘潭市| 兰州市| 策勒县| 桐梓县| 西贡区| 临沧市| 黔江区| 隆回县| 兰考县| 剑河县| 定结县| 黄浦区| 湖南省| 安岳县| 达尔| 丰城市| 马公市| 扎兰屯市| 柳江县| 吉水县| 岳阳市| 平陆县| 靖远县| 荣成市| 抚顺市| 治多县| 东丽区| 光山县| 垣曲县| 韶关市| 肥东县| 鸡泽县| 雅安市| 汾西县| 祁东县| 黄平县| 额济纳旗| 湘潭县| 南澳县|