本文实例讲述了Python实现的多进程和多线程功能。分享给大家供大家参考,具体如下:
听了朋友说起,他们目前开发的测试框架,用python实现的分布式系统。虽然python的执行效率没有c和c++那么高,但是依靠集群的力量,产生的压力很是牛逼啊。
了解了下大概的方式就是
1、有台主控机,负责调度,比如执行的参数等
2、有n多台执行机,每个执行机上部署一个python的xmlRPC server,主控机调用rpccall,然后执行机执行。rpccall里面会fork一些进程,每个进程再创建一些线程,去调用测试方法。这样,扩展性就很好了。
对于python的rpc call,之前也没有接触过,不是很了解,google了一下,发现很简单,拿了个网上的例子,如下,先部署一个rpcServer
from SimpleXMLRPCServer import SimpleXMLRPCServer def add(a , b): return a+bserver = SimpleXMLRPCServer(("10.249.192.38", 8000))#这里不要用localhost,否则只有本机才能访问 server.register_function(add) server.serve_forever()
客户端:
from xmlrpclib import Server Proxyserver = ServerProxy("http://localhost:8000") try: ret = server.add(30,90) print 'result:', ret print 'result type:', type(ret) except Exception, e: print "exception",e
其实还是很简单的。
然后再看了下python的多进程和多线程的方法,写了个例子,如下:
#encoding=utf-8 import sys import os import time import pdb import httplib import thread import threading constant_p = 0 #创建全局变量,进程数 constant_s = 0 #创建全局变量,线程数 mutex_g = threading.RLock() #创建全局锁 def run(count):#该函数创建3个线程,同时调用3个不同的函数 a = 1 b = 0 thread.start_new_thread(test0,(a,b))#这里传入的参数需要以元组的形式,跟void指针其实也差不多 thread.start_new_thread(test1,(a,b)) thread.start_new_thread(test2,(a,b)) def test0(a,b): global mutex_g global constant_s threadid = thread.get_ident() mutex_g.acquire()#这里需要把线程数说锁起来,否则结果会被修改 constant_s = constant_s+1 mutex_g.release() print "thread 0 called,and the threadid is:%d"%(threadid) sys.exit(0) def test1(a,b): global mutex_g global constant_s threadid = thread.get_ident() mutex_g.acquire() constant_s = constant_s+1 mutex_g.release() print "thread 1 called,and the threadid is:%d"%(threadid) sys.exit(0) def test2(a,b): global mutex_g global constant_s threadid = thread.get_ident() mutex_g.acquire() constant_s = constant_s+1 mutex_g.release() print "thread 2 called,and the threadid is:%d"%(threadid) sys.exit(0) def my_fork(): global constant_p pid = os.fork()#fork一个子进程,子进程的pid=0同时2个进程会执行my_fork()函数 if (pid == 0):#子进程执行到这个if里面 constant_p = constant_s + 1 run(3) time.sleep(5) print "total thread is %d"%constant_s#这个结果是3,因为子进程创建按了3个线程 elif (pid >0):#父进程执行到这个if里面 constant_p = constant_s + 1 run(4) time.sleep(5) print "total thread is %d"%constant_s#这个结果也是3,因为该进程也创建了3个线程 else: print "fork error" sys.exit(0) print "total process is %d"%constant_p#该结果是1,因为2个进程只执行了一次 constant_p = constant_s + 1 sys.exit(0) if __name__ == "__main__": my_fork() #my_fork() #my_fork()
更多关于Python相关内容感兴趣的读者可查看本站专题:《Python进程与线程操作技巧总结》、《Python Socket编程技巧总结》、《Python数据结构与算法教程》、《Python函数使用技巧总结》、《Python字符串操作技巧汇总》、《Python入门与进阶经典教程》及《Python文件与目录操作技巧汇总》
希望本文所述对大家Python程序设计有所帮助。
Python,多进程,多线程
免责声明:本站文章均来自网站采集或用户投稿,网站不提供任何软件下载或自行开发的软件! 如有用户或公司发现本站内容信息存在侵权行为,请邮件告知! 858582#qq.com
P70系列延期,华为新旗舰将在下月发布
3月20日消息,近期博主@数码闲聊站 透露,原定三月份发布的华为新旗舰P70系列延期发布,预计4月份上市。
而博主@定焦数码 爆料,华为的P70系列在定位上已经超过了Mate60,成为了重要的旗舰系列之一。它肩负着重返影像领域顶尖的使命。那么这次P70会带来哪些令人惊艳的创新呢?
根据目前爆料的消息来看,华为P70系列将推出三个版本,其中P70和P70 Pro采用了三角形的摄像头模组设计,而P70 Art则采用了与上一代P60 Art相似的不规则形状设计。这样的外观是否好看见仁见智,但辨识度绝对拉满。
更新日志
- 雨林唱片《赏》新曲+精选集SACD版[ISO][2.3G]
- 罗大佑与OK男女合唱团.1995-再会吧!素兰【音乐工厂】【WAV+CUE】
- 草蜢.1993-宝贝对不起(国)【宝丽金】【WAV+CUE】
- 杨培安.2009-抒·情(EP)【擎天娱乐】【WAV+CUE】
- 周慧敏《EndlessDream》[WAV+CUE]
- 彭芳《纯色角3》2007[WAV+CUE]
- 江志丰2008-今生为你[豪记][WAV+CUE]
- 罗大佑1994《恋曲2000》音乐工厂[WAV+CUE][1G]
- 群星《一首歌一个故事》赵英俊某些作品重唱企划[FLAC分轨][1G]
- 群星《网易云英文歌曲播放量TOP100》[MP3][1G]
- 方大同.2024-梦想家TheDreamer【赋音乐】【FLAC分轨】
- 李慧珍.2007-爱死了【华谊兄弟】【WAV+CUE】
- 王大文.2019-国际太空站【环球】【FLAC分轨】
- 群星《2022超好听的十倍音质网络歌曲(163)》U盘音乐[WAV分轨][1.1G]
- 童丽《啼笑姻缘》头版限量编号24K金碟[低速原抓WAV+CUE][1.1G]