温馨提示×

温馨提示×

您好,登录后才能下订单哦!

密码登录×
登录注册×
其他方式登录
点击 登录注册 即表示同意《亿速云用户服务条款》

怎么在Python的线程中运行协程

发布时间:2021-11-04 14:47:27 来源:亿速云 阅读:309 作者:iii 栏目:编程语言

这篇文章主要讲解了“怎么在Python的线程中运行协程”,文中的讲解内容简单清晰,易于学习与理解,下面请大家跟着小编的思路慢慢深入,一起来研究和学习“怎么在Python的线程中运行协程”吧!

有没有办法让同步代码与异步代码看起来也是同时运行的呢?方法就是使用事件循环的.run_in_executor()方法。

我们来看一下 Python 官方文档[1]中的说法:

怎么在Python的线程中运行协程

那么怎么使用呢?还是以非常耗时的递归方式计算斐波那契数列的这个函数为例:

def sync_calc_fib(n):     if n in [1, 2]:         return1     return sync_calc_fib(n - 1) + sync_calc_fib(n - 2)   async def calc_fib(n):     result = sync_calc_fib(n)     print(f'第 {n} 项计算完成,结果是:{result}')     return result

我们现在需要用 aiohttp 访问一个延迟5秒的网页,同时计算斐波那契数列第36项。

首先我们看看单独计算第36项需要5秒钟:

怎么在Python的线程中运行协程

我们再来看看如果直接把这计算斐波那契数列和请求网站的两个异步任务放在一起“并行”,实际时间是两个任务的时间叠加:

具体原因我在上一篇文章里面已经做了说明。

怎么在Python的线程中运行协程

现在,我想让两个任务“同时运行”,于是就可以这样修改代码:

import aiohttp import asyncio import time from concurrent.futures import ThreadPoolExecutor   async def request(sleep_time):     async with aiohttp.ClientSession() as client:         resp = await client.get(f'http://127.0.0.1:8000/sleep/{sleep_time}')         resp_json = await resp.json()         print(resp_json)   def sync_calc_fib(n):     if n in [1, 2]:         return 1     return sync_calc_fib(n - 1) + sync_calc_fib(n - 2)   def calc_fib(n):     result = sync_calc_fib(n)     print(f'第 {n} 项计算完成,结果是:{result}')     return result   async def main():     start = time.perf_counter()     loop = asyncio.get_event_loop()     with ThreadPoolExecutor(max_workers=4) as executor:         tasks_list = [             loop.run_in_executor(executor, calc_fib, 36),             asyncio.create_task(request(5))         ]         await asyncio.gather(*tasks_list)         end = time.perf_counter()         print(f'总计耗时:{end - start}')   asyncio.run(main())

运行效果如下图所示:

怎么在Python的线程中运行协程

在5秒钟的时间,就把计算斐波那契数列和请求5秒延迟的网站都做完了。

实现这样的转变,关键的代码就是:loop.run_in_executor(executor, calc_fib, 36)

其中的 loop就是主线程的事件循环(event loop),它是用来调度同一个线程里面的多个协程。

executor是我们使用ThreadPoolExecutor(max_workers=4)创建的一个有4个线程的线程池,calc_fib是一个耗时的同步函数,36是传入calc_fib的参数。loop.run_in_executor(executor,  calc_fib, 36)的意思是说:

  1. 把calc_fib函数放到线程池里面去运行

  2. 给线程池增加一个回调函数,这个回调函数会在运行结束后的下一次事件循环把结果保存下来。

请注意上图中红色箭头对应的calc_fib这是一个同步函数,请与上一篇文章中的异步函数区分开。run_in_executor的第二个参数需要是一个同步函数的函数名。

感谢各位的阅读,以上就是“怎么在Python的线程中运行协程”的内容了,经过本文的学习后,相信大家对怎么在Python的线程中运行协程这一问题有了更深刻的体会,具体使用情况还需要大家实践验证。这里是亿速云,小编将为大家推送更多相关知识点的文章,欢迎关注!

向AI问一下细节

免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。

AI