首页 > 系统服务 > 详细

多进程+协程 处理IO问题

时间:2018-11-20 13:05:21      阅读:212      评论:0      收藏:0      [点我收藏+]
from multiprocessing import Pool
import gevent,os
import time


def recursion(n):
    if n == 1 or n ==2:
        return 1
    else:
        return recursion(n-1)+recursion(n-2)


def f1(n):
    for i in range(1,n):
        print(%s递归运算%i,recursion(i))
        gevent.sleep(0.01)

def f2(n):
    s = []
    for i in range(n):
        s.append(i*i)
        print(%s列表计算%i,s[i])
        gevent.sleep(0.1)
        
def gevent_xc(num_1):

    g = [gevent.spawn(f1,num_1)]
    for item in g:
        item.join()

def gevent_2(num_1):
    g = [gevent.spawn(f2, num_1)]
    for item in g:
        item.join()


if __name__==__main__:
    start = time.clock()
    # 测试协程
    # g1 = gevent.spawn(f1,34)
    # g2 = gevent.spawn(f2,35)
    #
    # g1.join()
    # g2.join()

    # 测试进程
    pool = Pool(3)
    pool.apply_async(gevent_xc,(34,))
    pool.apply_async(gevent_2,(35,))
    pool.close()
    pool.join()
    print(time.clock()-start)

 

多进程+协程 处理IO问题

原文:https://www.cnblogs.com/wuzaipei/p/9987978.html

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