本文共 1368 字，大约阅读时间需要 4 分钟。

1.使用yield 来实现协程

import asyncioimport timeasync def job(t):                   # async 形式的功能    print('Start job ', t)    await asyncio.sleep(t)          # 等待 "t" 秒, 期间切换其他任务    print('Job ', t, ' takes ', t, ' s')    async def main(loop):                       # async 形式的功能    tasks = [    loop.create_task(job(t)) for t in range(1, 3)    ]                                       # 创建任务, 但是不执行    await asyncio.wait(tasks)               # 执行并等待所有任务完成t1 = time.time()loop = asyncio.get_event_loop()             # 建立 looploop.run_until_complete(main(loop))         # 执行 loop，并且等待所有任务结束loop.close()                                # 关闭 loopprint("Async total time : ", time.time() - t1)

执行结果：

Start job  1

Start job  2 Job  1  takes  1  s Job  2  takes  2  s Async total time :  2.01411509513855  

2. 使用greenlet 模块，通过switch来切换不同的代码块协程运行

from greenlet import greenletdef foo():    print("foo")    bar()def bar():    a = 3 + 1    print(a)    gr2.switch()    print("end bar")gr1 = greenlet(bar)gr2 = greenlet(foo)gr1.switch()

执行结果：

4

foo 4 end bar

3.使用gevent 模块实现协程

import requests

import gevent def f(url):     print('GET: %s' % url)     data = requests.get(url).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/'), ]) print("End of File")

执行结果：

转载地址：http://fkagi.baihongyu.com/