python 单线程和异步协程工作方式解析

from time import sleepimport asyncioasync def request(url):  print('正在请求url')  sleep(2)  print('下载成功')# 返回一个特殊的协程对象，request函数内部不会被执行c = request('www.baidu.com')# 实例化一个事件循环对象loop = asyncio.get_event_loop()# 基于事件循环对象创建一个任务对象,并将协程对象封装到该对象中task = loop.create_task(c)# 另一种形式实例化任务对象的方法task = asyncio.ensure_future(c)# 将协程对象注册到事件循环对象中，并需要启动事件循环对象# 当事件循环对象内的第一个参数遇到阻塞是，就会自动执行后面的对象，当第一个对象的阻塞结束是会上报给事件循环对象，然后事件循环对象继续执行第一个对象，从而达到异步的效果loop.run_until_complete(task)

import asyncioasync def request(url):  print('正在请求url')  print('下载成功')  return url# 回调函数必须有一个参数：task【任务对象】# task.result()：任务对象中封装的协程对象对应的特殊函数内部的返回值def callback(task):  print('this is callback')  print(task.result())c = request('www.baidu.com')# 创建一个任务对象task = asyncio.ensure_future(c)# 给任务对象绑定一个回调函数task.add_done_callback(callback)# 实例化一个事件循环对象loop = asyncio.get_event_loop()# 将协程对象注册到事件循环对象中，并需要启动事件循环对象loop.run_until_complete(task)

import asyncioimport timeurls = ['www.baidu.com','www.sogou,com','www.goubanjia.com']start_time = time.time()async def request(url):  print('正在请求url')  # 在多任务异步协程事项中，不可以出现不支持异步的相关代码，sleep不支持  # sleep(2)  await asyncio.sleep(2)  print('下载成功')loop = asyncio.get_event_loop()# 任务列表：防止多个任务对象tasks = []for url in urls:  c = request(url)  task = asyncio.ensure_future(c)  tasks.append(task)loop.run_until_complete(asyncio.wait(tasks))print(time.time() - start_time)

# aiohttp:支持异步的一个基于网络请求的模块import aiohttpimport asyncioimport timeurls = ['http://127.0.0.1:5000/jay',    'http://127.0.0.1:5000/bobo',    'http://127.0.0.1:5000/tom',]start_time = time.time()async def get_pageText(url):  async with aiohttp.ClientSession() as s:# 实例化请求对象    async with await s.get(url) as response:      page_text = await response.text()      print(page_text)      # 这里有返回值，是因为要用回调函数进行数据解析      return page_text# 封装回调函数用于数据解析def parse(task):  # 1.获取相应数据  page_text = task.reault()  print(page_text+'，即将进行数据解析...')  # 以下解析操作tasks = []for url in urls:  c = get_pageText(url)  task = asyncio.ensure_future(c)  # 给任务对象绑定回调函数用于数据解析  task.add_done_callback(parse)  tasks.append(task)loop = asyncio.get_event_loop()loop.run_until_complete(asyncio.wait(tasks))print(time.time() - start_time)