python 通信模块_python 多进程通信模块
多進程通信方法好多,不一而數。剛才試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)
創作挑戰賽新人創作獎勵來咯,堅持創作打卡瓜分現金大獎總結
以上是生活随笔為你收集整理的python 通信模块_python 多进程通信模块的全部內容,希望文章能夠幫你解決所遇到的問題。
 
                            
                        - 上一篇: java将一个对象赋值给另一个对象_ja
- 下一篇: psycopg2.errors.Unde
