python网络爬虫之协程的实现方法
1.协程
协程(Coroutine):又称微线程,是一种用户态内的上下文切换技术。
简而言之,就是通过一个线程实现代码块相互切换执行。
意义:在一个线程中如果遇到IO等待时间,线程不会傻傻等,会在空闲的时间再干其他事情。
一个线程,可以认为是人为的控制线程在函数之间进行线程切换,且仅有一个线程来完成切换。
实现协程的方法:
- greenlet 早期模块
- yield关键字 yield是python中的生成器
- asyncio装饰器(py3.4)
- async、await关键字(py3.5)【推荐】
1.1greenlet实现协程
安装:
pip install greenlet
# 1. greenlet实现协程
from greenlet import greenlet
def func1():
print(1) #第二步:输出1
gr2.swith() #第三步:切换到func2函数
print(2) #第六步:输出2
def func2():
print(3) #第四步:输出3
gr1.switch() #第五步:切换到func1函数
print(4) #第七步:输出4
gr1 = greenlet(func1())
gr2 = greenlet(func2())
gr1.switch() #第一步:执行func1函数1.2 yield关键字实现协程
# 2. yield关键字 实现协程
def func1(): #如果一个函数中,存在yield关键字,则认为是一个生成器,则执行该函数,就生成一个生成器
yield 1 #第二步:输出1
yield from func2() #第三步:表示跳到func2函数中
yield 2 #第六步:输出2
def func2():
yield 3 #第四步:输出3
yield 4 #第五步:输出4
f1 = func1()
for item in f1:
print(item) #第一步:执行func1函数1.3 asyncio 实现协程
# 3. asyncio 实现协程【无需安装,但要求python需3.4及以上版本】
# 注意:遇到IO阻塞自动切换
import asyncio
@asyncio.coroutine
def func1(): #func1位普通函数,添加了asynic.coroutine装饰器后,则认为该函数为协程函数
print(1)
yield from asyncio.sleep(2) # 遇到IO耗时操作,自动切换到tasks中的其他任务
print(2)
@asyncio.coroutine
def func2():
print(3)
yield from asyncio.sleep(2) # 遇到IO耗时操作,自动切换到tasks中的其他任务
print(4)
#协程函数的执行, 则无法使用func1()方法进行执行,需要以下的方法进行执行
# loop = asyncio.get_event_loop()
# loop.run_until_complete(函数名称) #使用以上代码,执行函数的协程操作 如:loop.run_until_complete(func())
#对func1和func2函数进行封装, 然后使用下面的4句代码,在pyhton内部,同时会执行这两个协程函数,线程会随机执行所有函数中的一个
tasks = [
asyncio.ensure_future(func1()),
asyncio.ensure_future(func2())
]
# 线程函数会随机执行func1和func2协程函数
loop = asyncio.get_event_loop()
loop.run_until_complete(asyncio.wait(tasks))假设首先执行func1函数,则在遇到 yield from asyncio.sleep(2),线程会跳转到其他协程函数中,但因为该python文件中仅有2个协程函数,
#因此,跳转执行func2函数,而在func2函数中遇到yield from asyncio.sleep(2),就又会跳转到func1函数冲,输出2,最后再到func2函数中,输出4.结束本次操作
#本代码输出结果为: 1 3 2 4
1.4 asyn &await 实现协程
# 4. async & await关键字【推荐】 在python3.5及以上
import asyncio
async def func1(): #func1位普通函数,添加了asynic.coroutine装饰器后,则认为该函数为协程函数
print(1)
await asyncio.sleep(2) # 遇到IO耗时操作,自动切换到tasks中的其他任务
print(2)
@asyncio.coroutine
async def func2():
print(3)
await asyncio.sleep(2) # 遇到IO耗时操作,自动切换到tasks中的其他任务
print(4)
#对func1和func2函数进行封装, 然后使用下面的4句代码,在pyhton内部,同时会执行这两个协程函数,线程会随机执行所有函数中的一个
tasks = [
asyncio.ensure_future(func1()),
asyncio.ensure_future(func2())
]
# 线程函数会随机执行func1和func2协程函数
loop = asyncio.get_event_loop()
loop.run_until_complete(asyncio.wait(tasks))#说明:asyncio和 async & await区别不大,只是将@asyncio.coroutine替换为 asyn ;将yield from 替成 await,其他的都没变
到此这篇关于python网络爬虫之协程的实现方法的文章就介绍到这了,更多相关python网络爬虫之协程内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家!
相关文章
Django使用 Bootstrap 样式修改书籍列表过程解析
这篇文章主要介绍了Django使用 Bootstrap 样式修改书籍列表过程解析,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下2019-08-08
Python Excel高阶教程之使用 Spire.XLS创建雷达图和折线图
Spire.XLS for Python 库提供了便捷的图表创建功能,让开发者能够仅用几行代码就创建各种如柱形图、条形图等专业图表,下面就跟随小编一起来看看具体实现方法吧2025-08-08
使用 OpenAI API 和 Python 使用 GPT-3的操作方法
这篇文章主要介绍了使用 OpenAI API 和 Python 使用 GPT-3,在本文中,我们将使用 GPT-3。我将向您展示如何访问它,并提供一些示例来说明您可以使用它做什么,以及您可以使用它构建什么样的应用程序,需要的朋友可以参考下2023-03-03


最新评论