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

如果我们在单个线程内有20个任务,要想实现在多个任务之间切换,使用greenlet模块可以非常简单地实现这20个任务直接的切换
使用yield生成器的方式过于麻烦(需要先得到初始化一次的生成器,然后再调用send。。。非常麻烦)

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

  

(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对象

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

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

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

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

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

  (2)等待2s,阻塞中,不切换

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

  

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

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

2、gevent模块:阻塞也切换

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

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

  (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的返回值

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

  (2)遇到IO阻塞时会自动切换任务

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

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

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

  (3)不能识别其他阻塞:time.sleep(2)

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

  (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))

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

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

  

3、gevent异步提交任务

  (1)创建未执行,程序就结束了

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

  (2)主:sleep 1s

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

  (3)主sleep 5s

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

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

  (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会提前完成

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

4

5

04-26 13:55