在Python 的线程中运行协程的方法

在一篇文章 理解Python异步编程的基本原理 这篇文章中，我们讲到，如果在异步代码里面又包含了一段非常耗时的同步代码，异步代码就会被卡住。

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

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

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

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

在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)的意思是说：

• 把calc_fib函数放到线程池里面去运行
• 给线程池增加一个回调函数，这个回调函数会在运行结束后的下一次事件循环把结果保存下来。

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

在上面的例子中，我们创建的是有4个线程的线程池。所以这个线程池最多允许4个阻塞式的同步函数“并行”。

总结

到此这篇关于在Python 的线程中运行协程的方法的文章就介绍到这了,更多相关python线程中运行协程内容请搜索来客网以前的文章或继续浏览下面的相关文章希望大家以后多多支持来客网！