最新国产好看的视频,伊人天堂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)論

连州市| 招远市| 通海县| 德庆县| 泸水县| 紫云| 离岛区| 玛纳斯县| 南丹县| 澎湖县| 金阳县| 思南县| 东阳市| 鄂托克旗| 凌源市| 沙湾县| 怀宁县| 涿州市| 荣昌县| 陇西县| 招远市| 灵宝市| 漳平市| 仁化县| 普安县| 潼南县| 南安市| 龙泉市| 平乐县| 页游| 永年县| 婺源县| 龙南县| 西乌珠穆沁旗| 孟村| 蕉岭县| 宁城县| 清苑县| 卫辉市| 武宣县| 巴青县|