首页 > 编程语言 > 详细

Python创建多进程,用Queue传递信息

时间:2015-05-26 00:11:57      阅读:208      评论:0      收藏:0      [点我收藏+]

创建10个进程,分别计算0到1000各个区间的和,主进程汇总

 

__author__ = Administrator
# -*- coding:utf-8 -*-

‘‘‘
@author:qiushui
‘‘‘

import os
import threading
import multiprocessing
import Queue

def calculator(q, calContext):
    sumCal = 0;
    for i in range(calContext[0], calContext[1],1):
        sumCal += i;
    q.put(sumCal)

lst = range(0,1000,1)
i = 0
q = multiprocessing.Queue();

if __name__ == "__main__":
    while i <= 1000:
        p = multiprocessing.Process(target=calculator, args=(q,(i,(i+1)*100)))
        p.start()
        p.join()
        i += 100;
    result = 0
    while not q.empty():
        element = q.get()
        result+=element
    print("result = " + repr(result))

 

Python创建多进程,用Queue传递信息

原文:http://www.cnblogs.com/doudouyoutang/p/4529256.html

(0)
(0)
   
举报
评论 一句话评论(0
关于我们 - 联系我们 - 留言反馈 - 联系我们:wmxa8@hotmail.com
© 2014 bubuko.com 版权所有
打开技术之扣,分享程序人生!