python异步IO-asyncio、async和await

参考链接:

  asyncio:https://www.liaoxuefeng.com/wiki/0014316089557264a6b348958f449949df42a6d3a2e542c000/001432090954004980bd351f2cd4cc18c9e6c06d855c498000

  async与await:https://www.liaoxuefeng.com/wiki/0014316089557264a6b348958f449949df42a6d3a2e542c000/00144661533005329786387b5684be385062a121e834ac7000

总结:

   asynico 提供了完善的异步IO支持、异步操作(有的是异步操作,不是协程)需要在 coroutine 里通过 yield from 语句引入、多个 coroutine 可以封装成一组Task实现并发执行

  用 asyncio 提供的 @asyncio.coroutine 可以把一个 generator 标记为 coroutine 类型,然后在 coroutine 内部用 yield from 调用另一个 coroutine 实现异步操作

一、  asyncio的编程模型就是一个消息循环,我们从 asyncio 中直接取一个 eventloop 的引用,然后把要执行的协程扔到这个引用里面执行,这样就实现了异步IO

import asyncio
@asyncio.coroutine
def hello():
    print(‘Hello world!‘)
    #异步调用asynico.sleep(1)
    r=yield from asyncio.sleep(1)
    print(‘Hello again!‘)

#获取eventloop
loop=asyncio.get_event_loop()
#执行coroutine(协程)
loop.run_until_complete(hello())
loop.close()

  首先, @asyncio.coroutine 将一个 generator 标记为 coroutine 类型,然后将这个 coroutine 放到 eventloop (事件循环)里面执行

  hello()会首先打印出‘Hello world!’, rield form  语句可以让我们方便的调用 generator ,同时 asyncio.sleep(1) 也是一个 coroutine ,所以线程并不会等待它执行完,而是直接中断执行下一个消息循环(即处理其他的协程?),当这条语句执行完毕后,消息循环会通过 yield from 返回值(实际是None),然后再继续执行下一条语句

  把 asyncio.sleep(1) 看作为耗时一秒的IO操作,在此期间,线程并不会等待这个 coroutine ,而是转而执行 eventloop 中其他的 coroutine ,从而实现了并发

  让我疑惑的一点是,上述并发给我的感觉是两个 coroutine 之间执行进度是互不影响的,即Hello world! 与Hello again!之间并不会等待1秒,但从结果来看并不是这样

Hello world!
【中间暂停1秒】
Hello again!

  这可能是上面 eventloop 中只有一个协程(可不是说 asyncio.sleep(1) 也是一个 coroutine 吗?,难道是根据 loop.run_until_complete(hello()) 来判定只有一个协程是hello()吗?)嗯,好想是这样的,因为后面向 eventloop 里面扔进去的都是task

二、  用Task来封装两个 coroutine

import threading
import asyncio

@asyncio.coroutine
def hello():
    print(‘Hello world! (%s)‘ % threading.currentThread())
    yield from asyncio.sleep(1)
    print(‘Hello again! (%s)‘ % threading.currentThread())

loop=asyncio.get_event_loop()
tasks=[hello(),hello()]
loop.run_until_complete(asyncio.wait(tasks))
loop.close()

  执行过程

Hello world! (<_MainThread(MainThread, started 140735195337472)>)
Hello world! (<_MainThread(MainThread, started 140735195337472)>)
(暂停约1秒)
Hello again! (<_MainThread(MainThread, started 140735195337472)>)
Hello again! (<_MainThread(MainThread, started 140735195337472)>)

由打印的当前线程名称可以看出,两个 coroutine 是由同一个线程并发执行的。

我不清楚这个task是怎样使用的,但是从上面结果来看,很容易就可以看出两个hello(虽然他们是一模一样的两个)是交替运行的

如果把 asyncio.sleep() 换成真正的IO操作,则多个 coroutine 就可以由一个线程并发执行。

三、通过展示一个用 asyncio 的异步网络连接来获取sina、sohu和163的网站首页的例子直观的展现了三个连接可以死并发(即交替)执行的。

import asyncio

@asyncio.coroutine
def wget(host):
    print(‘wget %s...‘ % host)
    connect=asyncio.open_connection(host,80)
    reader,writer=yield from connect
    header=‘Get / HTTP/1.0\r\nHost:%s\r\n\r\n‘ %host  #不要拼写错
    writer.write(header.encode(‘utf-8‘))
    yield from writer.drain()
    while True:
        line=yield from reader.readline()
        if line==b‘\r\n‘:
            break
        print(‘%s header>%s‘%(host,line.decode(‘utf-8‘).rstrip()))
        #忽略body,关闭socket
    writer.close()

loop=asyncio.get_event_loop()
tasks=[wget(host) for host in [‘www.sina.com.cn‘,‘www.sohu.com‘,‘www.163.com‘]]
#使用了列表生成式
loop.run_until_complete(asyncio.wait(tasks))
loop.close()

  执行结果

wget www.sohu.com...
wget www.sina.com.cn...
wget www.163.com...
(等待一段时间)
(打印出sohu的header)
www.sohu.com header > HTTP/1.1 200 OK
www.sohu.com header > Content-Type: text/html
...
(打印出sina的header)
www.sina.com.cn header > HTTP/1.1 200 OK
www.sina.com.cn header > Date: Wed, 20 May 2015 04:56:33 GMT
...
(打印出163的header)
www.163.com header > HTTP/1.0 302 Moved Temporarily
www.163.com header > Server: Cdn Cache Server V2.0
...

四、  

async 与 await 是python3.5引入的新语法,为了让 coroutine 的语法更简介,用来代替 @asyncio.coroutine 和 yield from 的

请注意, async 和 await 是针对 coroutine 的新语法,要使用新的语法,只需要做两步简单的替换:

  1. 把 @asyncio.coroutine 替换为 async ;(这步哈哈)
  2. 把 yield from 替换为 await 。

原文地址:https://www.cnblogs.com/Gaoqiking/p/10625341.html

时间: 2024-11-06 07:29:21

python异步IO-asyncio、async和await的相关文章

Python异步IO --- 轻松管理10k+并发连接

前言 异步操作在计算机软硬件体系中是一个普遍概念,根源在于参与协作的各实体处理速度上有明显差异.软件开发中遇到的多数情况是CPU与IO的速度不匹配,所以异步IO存在于各种编程框架中,客户端比如浏览器,服务端比如node.js.本文主要分析Python异步IO. Python 3.4标准库有一个新模块asyncio,用来支持异步IO,不过目前API状态是provisional,意味着不保证向后兼容性,甚至可能从标准库中移除(可能性极低).如果关注PEP和Python-Dev会发现该模块酝酿了很长时

异步编程(Async和Await)的使用

.net4.5新特性之异步编程(Async和Await)的使用 一.简介 首先来看看.net的发展中的各个阶段的特性:NET 与C# 的每个版本发布都是有一个“主题”.即:C#1.0托管代码→C#2.0泛型→C#3.0LINQ→C#4.0动态语言→C#4.5异步编程 下面我来简单的介绍一下异步编程:异步编程,在 .NET Framework 4.5 和 Windows 运行时利用异步支持. 编译器可执行开发人员曾进行的高难度工作,且应用程序保留了一个类似于同步代码的逻辑结构. 因此,你只需做一小

Python异步IO之协程(一):从yield from到async的使用

引言:协程(coroutine)是Python中一直较为难理解的知识,但其在多任务协作中体现的效率又极为的突出.众所周知,Python中执行多任务还可以通过多进程或一个进程中的多线程来执行,但两者之中均存在一些缺点.因此,我们引出了协程. Tips 欲看完整代码请见:我的GitHub 为什么需要协程?首先,我们需要知道同步和异步是什么东东,不知道的看详解.简单来说:[同步]:就是发出一个“调用”时,在没有得到结果之前,该“调用”就不返回,“调用者”需要一直等待该“调用”结束,才能进行下一步工作.

Python异步IO之协程(二):使用asyncio的不同方法实现协程

引言:在上一章中我们介绍了从yield from的来源到async的使用,并在最后以asyncio.wait()方法实现协程,下面我们通过不同控制结构来实现协程,让我们一起来看看他们的不同作用吧- 在多个协程中的线性控制流很容易通过内置的关键词await来管理.使用asyncio模块中的方法可以实现更多复杂的结构,它可以并发地完成多个协程. 一.asyncio.wait() 你可以将一个操作分成多个部分并分开执行,而wait(tasks)可以被用于中断任务集合(tasks)中的某个被事件循环轮询

Python异步IO

在IO操作的过程中,当前线程被挂起,而其他需要CPU执行的代码就无法被当前线程执行了. 我们可以使用多线程或者多进程来并发执行代码,为多个用户服务. 但是,一旦线程数量过多,CPU的时间就花在线程切换上了,真正运行代码的时间就少了,结果导致性能严重下降. 异步IO:当代码需要执行一个耗时的IO操作时,它只发出IO指令,并不等待IO结果,然后就去执行其他代码了.一段时间后,当IO返回结果时,再通知CPU进行处理. 对于大多数IO密集型的应用程序,使用异步IO将大大提升系统的多任务处理能力. 1.

Python 3.5的async和await特性(PEP492翻译)

原因: 1,coroutine容易与正常的generators弄混 2,一个function是否为coroutine由函数体内是否有yield 或者yield from 决定,这不科学. 3,如果在语法上允许yield的地方才能进行异步调用,那诸如with和for语句中都不能执行异步了. 咋解决呢,把coroutine当成一个native的Python语言特性,与generator完全独立. Native coroutines及其新的语法使得在异步条件下定义context manager(上下文

多线程之异步编程: 经典和最新的异步编程模型,async与await

经典的异步编程模型(IAsyncResult) 最新的异步编程模型(async 和 await) 将 IAsyncInfo 转换成 Task 将 Task 转换成 IAsyncInfo 示例1.使用经典的异步编程模型(IAsyncResult)实现一个支持异步操作的类Thread/Async/ClassicAsync.cs /* * 使用经典的异步编程模型(IAsyncResult)实现一个支持异步操作的类 */ using System; using System.Collections.Ge

.NET异步编程初识async与await

这是两个关键字,用于异步编程.我们传统的异步编程方式一般是Thread.ThreadPool.BeginXXX.EndXXX等等.把调用.回调分开来,代码的逻辑是有跳跃的,于是会导致思路不是很清晰的问题,在.NET 4.5中,新推出的async.await关键字,可以帮助我们像写同步方法一样去写异步方法(保证代码的整齐清晰). 先来看个传统同步方法例子: 1 static void Main(string[] args) 2 { 3 // 同步方式 4 Console.WriteLine("同步

Python 异步IO、IO多路复用

事件驱动模型 1 <!DOCTYPE html> 2 <html lang="en"> 3 <head> 4 <meta charset="UTF-8"> 5 <title>Title</title> 6 7 </head> 8 <body> 9 10 <p onclick="fun()">点我呀</p> 11 12 13 &l