协程
协程的特点是利用任务的阻塞时间去处理其他任务
处理任务的是线程，而协程是单线程，占用资源由大到小排：多进程>多进程>协程
gevent模块封装greenlet模块，greenlet模块封装yield
在gevent里使用tiem.sleep会失效，需要使用gevent.sleep，或者使用monkey补丁实现替换
如代码因为monkey.patch_all()补丁问题报错，将from gevent import monkey和补丁代码放到最前面尝试
使用协程完成多任务三个例子：
使用yield实现
import time
def func1():
while True:
print("---1---")
time.sleep(0.1)
yield
def func2():
while True:
print("---2---")
time.sleep(0.1)
yield
def main():
t1 = func1()
t2 = func2()
while True:
next(t1)
next(t2)
if __name__ == "__main__":
main()使用greenlet实现
import time
from greenlet import greenlet
def func1():
while True:
print("---1---")
gr2.switch()
time.sleep(0.1)
def func2():
while True:
print("---2---")
gr1.switch()
time.sleep(0.1)
gr1 = greenlet(func1)
gr2 = greenlet(func2)
# 切换到gr1中运行
gr1.switch()使用gevent实现
import time
import gevent
from gevent import monkey
# 打补丁，检查所有耗时操作中存在time.sleep(),自动替换为gevent.sleep()
monkey.patch_all()
def func1(n):
for i in range(n):
print(gevent.getcurrent(), i)
time.sleep(0.5) # 如未打补丁monkey，time的延时没有效果
# gevent.sleep(0.5)
def func2(n):
for i in range(n):
print(gevent.getcurrent(), i)
time.sleep(0.5) # 如未打补丁monkey，time的延时没有效果
# gevent.sleep(0.5)
def func3(n):
for i in range(n):
print(gevent.getcurrent(), i)
time.sleep(0.5) # 如未打补丁monkey，time的延时没有效果
# gevent.sleep(0.5)
print("---1---")
g1 = gevent.spawn(func1, 5)
print("---2---")
g2 = gevent.spawn(func2, 5)
print("---3---")
g3 = gevent.spawn(func3, 5)
print("---4---")
# 协程的最大特点就是利用某个任务阻塞的时间去处理其他任务
# 等待执行
gevent.joinall([
gevent.spawn(func1, 5),
gevent.spawn(func2, 5),
gevent.spawn(func3, 5)
])
# g1.join()
# g2.join()
# g3.join()本文参与 腾讯云自媒体分享计划，分享自作者个人站点/博客。
原始发表：2019-05-12 ，如有侵权请联系 cloudcommunity@tencent.com 删除
评论
登录后参与评论
推荐阅读