标签:-- 切片 封装 receive 上下 greenlet 并发处理 == text
协程(corouutine):轻量级的线程,不存在上下文切换,能在多个任务之间调度的多任务方式,可以使用,yield实现
线程和进程的操作是由程序触发系统接口,最后的执行者是系统,它本质上是操作系统提供的功能。而协程的操作则是程序员指定的,在python中通过yield,人为的实现并发处理。
协程存在的意义:对于多线程应用,CPU通过切片的方式来切换线程间的执行,线程切换时需要耗时。协程,则只使用一个线程,分解一个线程成为多个“微线程”,在一个线程中规定某个代码块的执行顺序。
协程的适用场景:当程序中存在大量不需要CPU的操作时(IO)。
简单多任务协程实列:
import time
import threading
def task_1():
print(threading.current_thread())
while True:
print(‘---1---‘)
time.sleep(1)
yield
def task_2():
print(threading.current_thread())
while True:
print(‘---2---‘)
time.sleep(1)
yield
def main():
t1=task_1()
t2=task_2()
while True:
next(t1)
next(t2)
if __name__ == ‘__main__‘:
main()
在不需要自己“造轮子”的年代,同样有第三方模块为我们提供了高效的协程,这里介绍一下greenlet和gevent。本质上,gevent是对greenlet的高级封装,因此一般用它就行,这是一个相当高效的模块。
在使用它们之前,需要先安装,可以通过源码,也可以通过pip。
greenlet
def test1():
print(12)
gr2.switch()
print(34)
gr2.switch()
def test2():
print(56)
gr1.switch()
print(78)
gr1 = greenlet(test1)
gr2 = greenlet(test2)
gr1.switch()
gevent
from gevent import monkey; monkey.patch_all()
import gevent
import requests
def f(url):
print(‘GET: %s‘ % url)
resp = requests.get(url)
data = resp.text
print(‘%d bytes received from %s.‘ % (len(data), url))
gevent.joinall([
gevent.spawn(f, ‘https://www.python.org/‘),
gevent.spawn(f, ‘https://www.yahoo.com/‘),
gevent.spawn(f, ‘https://github.com/‘),
])
标签:-- 切片 封装 receive 上下 greenlet 并发处理 == text
原文地址:https://www.cnblogs.com/fan-1994716/p/11873192.html