码迷,mamicode.com
首页 > 编程语言 > 详细

python 并行处理数据

时间:2019-11-10 22:38:02      阅读:65      评论:0      收藏:0      [点我收藏+]

标签:func   int   pre   http   sleep   并行处理   ==   async   style   

来源:https://blog.csdn.net/weixin_42001089/article/details/88843152

import multiprocessing
import time
import os
print("温馨提示:本机为",os.cpu_count(),"核CPU")  
 
def func(msg):
    print "msg:", msg
    time.sleep(3)
    print "end"
 
if __name__ == "__main__":
    #这里开启了4个进程
    pool = multiprocessing.Pool(processes = 4)
    for i in xrange(4):
        msg = "hello %d" %(i)
        pool.apply_async(func, (msg, ))   
 
    pool.close()
    pool.join()   #调用join之前,先调用close函数,否则会出错。执行完close后不会有新的进程加入到pool,join函数等待所有子进程结束
    print "Successfully"

 

python 并行处理数据

标签:func   int   pre   http   sleep   并行处理   ==   async   style   

原文地址:https://www.cnblogs.com/yibeimingyue/p/11832104.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有 京ICP备13008772号-2
迷上了代码!