Python 多进程应用示例
2015-04-02 10:59
323 查看
import multiprocessing import time def func(name): outputline=name for i in range(3): outputline+= " repeat "+str(i) time.sleep(1) return outputline def main(): pool=multiprocessing.Pool(processes=4) result=[] for i in range(4): pname="cpu_%d"%i result.append(pool.apply_async(func, (pname, ))) pool.close() pool.join() for res in result: print res.get() print "all processes done" if __name__ == '__main__': main()
示例2,使用锁同步
import multiprocessing import time def func(name,lock): outputline=name for i in range(3): outputline+= " repeat "+str(i) lock.acquire() print name+" repeat "+str(i) lock.release() time.sleep(1) return outputline def main(): lock=multiprocessing.Lock() subprocesses=[] for i in range(4): pname="cpu_%d"%i process=multiprocessing.Process(target=func, args=(pname,lock)) process.start() subprocesses.append(process) for p in subprocesses: p.join() print "all processes done" if __name__ == '__main__': main()
ref:
http://www.coder4.com/archives/3352 http://www.cnblogs.com/vamei/archive/2012/10/12/2721484.html
相关文章推荐
- CGI介绍及使用Python来开发CGI应用示例
- python线程应用示例
- Python多进程multiprocessing使用示例
- Python logger模块应用示例
- python: mongodb应用示例
- Python enumerate遍历数组示例应用
- 基于Python多线程的TCP客户端/服务端应用示例
- 设计模式中的原型模式在Python程序中的应用示例
- 设计模式中的原型模式在Python程序中的应用示例
- python多进程示例
- Python解析XML正确应用代码示例讲解
- Python压缩文件基本应用代码示例解读
- Python学习日志之三-----Python小应用示例
- Python基于sklearn库的分类算法简单应用示例
- python Multiprocessing 多进程应用
- Python压缩文件基本应用代码示例解读
- Ajax前台与Mod_python后台应用示例
- Python(2.7.x)数据库应用的简单示例
- python flask make_response的应用示例
- 基于Python的TCP服务端/客户端简单应用示例