10-[协程] greenlet模块、 gevent模块

1、greenlet模块：实现20个任务切换

如果我们在单个线程内有20个任务，要想实现在多个任务之间切换，使用greenlet模块可以非常简单地实现这20个任务直接的切换

使用yield生成器的方式过于麻烦（需要先得到初始化一次的生成器，然后再调用send。。。非常麻烦）

　　

（1）switch 开关：执行greenlet对象

# 一个线程里面有20个任务,实现在多个任务之间切换

# pip install greenlet  # 安装失败

from greenlet import greenlet

# eta

def eat(name):

    print('%s eat 1' % name)

    print('%s eat 2' % name)

def play(name):

    print('%s play 1' % name)

    print('%s play 2' % name)

g1 = greenlet(eat)      # 创建一个greenlet对象

g2 = greenlet(play)

g1.switch('alex')   # 开关： run greenlet对象

　　（2）g2.switch()：接着上次的阻塞继续执行

　　（2）等待2s，阻塞中，不切换

greenlet只是提供了一种比generator更加便捷的切换方式，当切到一个任务执行时如果遇到io，那就原地阻塞，仍然是没有解决遇到IO自动切换来提升效率的问题。

　　

2、gevent模块:阻塞也切换

单线程里的这20个任务的代码通常会既有计算操作又有阻塞操作，我们完全可以在执行任务1时遇到阻塞，就利用阻塞的时间去执行任务2。。。。如此，才能提高效率，这就用到了Gevent模块。

　　

　　（1）用法

g1=gevent.spawn(func,1,,2,3,x=4,y=5)

#创建一个协程对象g1，

        spawn括号内第一个参数是函数名，如eat，

        后面可以有多个参数，可以是位置实参或关键字实参，都是传给函数eat的

g2=gevent.spawn(func2)

g1.join() #等待g1结束

g2.join() #等待g2结束

#或者上述两步合作一步：

gevent.joinall([g1,g2])

g1.value    #拿到func1的返回值        

　　（2）遇到IO阻塞时会自动切换任务

gevent.sleep(2)模拟的是gevent可以识别的io阻塞

　　（3）不能识别其他阻塞：time.sleep(2)

　　（4）from gevent import monkey;monkey.patch_all()

而time.sleep(2)或其他的阻塞,gevent是不能直接识别的

需要用下面一行代码,打补丁,就可以识别了from gevent import monkey;monkey.patch_all()必须放到被打补丁者的前面，如time，socket模块之前

或者我们干脆记忆成：要用gevent，需要将from gevent import monkey;monkey.patch_all()放到文件的开头

　　

import gevent  # 实现并发同步与异步编程

import time

from gevent import monkey; monkey.patch_all()  # 识别其他的阻塞

def eat(name):

    print('%s eat 1' % name)

    time.sleep(2)       # 遇到阻塞时会自动切换任务

    print('%s eat 2' % name)

def play(name):

    print('%s play 1' % name)

    time.sleep(3)

    print('%s play 2' % name)

start_time = time.time()

g1 = gevent.spawn(eat, 'akex')

g2 = gevent.spawn(play, 'jack')

g1.join()

g2.join()

print('<%s>' % (time.time()-start_time))

我们可以用threading.current_thread().getName()来查看每个g1和g2，查看的结果为DummyThread-n，即假线程

　　

3、gevent异步提交任务

　　（1）创建未执行，程序就结束了

　　（2）主：sleep 1s

 

　　（3）主sleep 5s

　　（4）g2.join()

import gevent

import time

from gevent import monkey; monkey.patch_all() # 识别其他的阻塞

def eat(name):

    print('%s eat 1' % name)

    time.sleep(2)       # 遇到阻塞时会自动切换任务

    print('%s eat 2' % name)

def play(name):

    print('%s play 1' % name)

    time.sleep(3)

    print('%s play 2' % name)

g1 = gevent.spawn(eat, 'akex')

g2 = gevent.spawn(play, 'jack')

# g1.join()      # g1完成 g2不会完成

g2.join()  # 由于g2需要花费3s，g1花费2s。 因此只需要等待g2完成即可，g1会提前完成

  

4

5