| 站点地图 | 联系我
| www.asm32.net | 2006版 | 资料中心 | linux | asm/asm32 | C/C++ | VC++ | java | 书签 | ASP.Net书签 | 上善若水 厚德载物
 现在位置 :: 主页 >> 资料中心 >> ROOT / CODE / Python /
 

python 多进程通信模块

来源(PythonTab:Python中文开发者社区门户)

From: http://www.pythontab.com/html/2014/pythonhexinbiancheng_0224/704.html

python 多进程通信模块

2014-02-24 10:53:13 来源:

多进程通信方法好多,不一而数。刚才试python封装好嘅多进程通信模块 multiprocessing connection。简单测试一下,效率还可以,应该系对so

多进程通信方法好多,不一而数。刚才试python封装好嘅多进程通信模块 multiprocessing.connection。

简单测试一下,效率还可以,应该系对socket封装,效率可以达到4krps,可以满足好多方面嘅需求啦。

附代码如下:

client

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

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


如对本文内容有疑问,或想进一步交流学习,欢迎通过以下方式:

1. PythonTab论坛

2. pythontab技术互助群 群2:333646237 PythonTab技术互助群2 群 1:87464755 PythonTab技术互助群1

3. 关注PythonTab微信,获取精彩资讯教程,公众号:Pythontab中文网

Link: http://www.asm32.net/article_details.aspx?id=6239


浏览次数 0 发布时间 2014/3/6 10:23:22 从属分类 Python 【评论】【 】【打印】【关闭
 
| www.asm32.net | 2006版 | 资料中心 | linux | asm/asm32 | C/C++ | VC++ | java | 书签 | ASP.Net书签 | 京ICP备09029108号-1