位置: 编程技术 - 正文
Python中使用asyncio 封装文件读写(python asyncio)
编辑：rootadmin推荐整理分享Python中使用asyncio 封装文件读写(python asyncio)，希望有所帮助，仅作参考，欢迎阅读内容。
文章相关热门搜索词:python asyncio await,python asyncio,python的async await,python的async await,python asyncio,python asyncio,PYTHON中使用什么关键字可以在当前程序中,python asyncio,内容如对您有帮助，希望把文章链接给更多的朋友！
前言
和网络 IO 一样，文件读写同样是一个费事的操作。
默认情况下，Python 使用的是系统的阻塞读写。这意味着在 asyncio 中如果调用了
会阻塞事件循环。
本篇简述如何用 asyncio.Future 对象来封装文件的异步读写。
代码在 GitHub。目前仅支持 Linux。
阻塞和非阻塞
首先需要将文件的读写改为非阻塞的形式。在非阻塞情况下，每次调用 read 都会立即返回，如果返回值为空，则意味着文件操作还未完成，反之则是读取的文件内容。
阻塞和非阻塞的切换与操作系统有关，所以本篇暂时只写了 Linux 版本。如果有过 Unix 系统编程经验，会发现 Python 的操作是类似的。
Future 对象
Future 对象类似 Javascript 中的 Promise 对象。它是一个占位符，其值会在将来被计算出来。我们可以使用
result = await future
在 future 得到值之后返回。而使用
future.set_result(xxx)
就可以设置 future 的值，也意味着 future 可以被返回了。await 操作符会自动调用 future.result() 来得到值。
loop.call_soon
通过 loop.call_soon 方法可以将一个函数插入到事件循环中。
至此，我们的异步文件读写思路也就出来了。通过 loop.call_soon 调用非阻塞读写文件的函数。若一次文件读写没有完成，则计算剩余所学读写的字节数，并再次插入事件循环直至读写完毕。
可以发现其就是把传统 Unix 编程里，非阻塞文件读写的 while 循环换成了 asyncio 的事件循环。
下面是这一过程的示意代码。
asyncio 的 coroutine对象 与 Future对象使用指南 coroutine与Future的关系看起来两者是一样的，因为都可以用以下的语法来异步获取结果，result=awaitfutureresult=awaitcoroutine实际上，coroutine是生成器函数，它
基于asyncio 异步协程框架实现收集B站直播弹幕 前言虽然标题是全站，但目前只做了等级top直播间的全天弹幕收集。弹幕收集系统基于之前的B站直播弹幕姬Python版修改而来。具体协议分析可以看上
python开发环境PyScripter中文乱码问题解决方案 PyScripter看起来还是挺不错的一个pythonide环境:PyScripter2.6.0.0python3.4问题：PyScripter有个小坑，打开文件后中文都成了乱码。在PyScripter中新建的文件中文可
标签: python asyncio
本文链接地址:https://www.jiuchutong.com/biancheng/385413.html 转载请保留说明！上一篇：Python 如何访问外围作用域中的变量(python 如何访问数据库)
下一篇：asyncio 的 coroutine对象 与 Future对象使用指南
![把文件名当中含有特殊字符[.]的文件删除的方法(文件名可以包含*吗)](https://www.jiuchutong.com/image/20240129/1706504410.jpg)
