[Python知识库] python中的协程示例

开发: C++知识库 Java知识库 JavaScript Python PHP知识库人工智能区块链大数据移动开发嵌入式开发工具数据结构与算法开发测试游戏开发网络协议系统运维
教程: HTML教程 CSS教程 JavaScript教程 Go语言教程 JQuery教程 VUE教程 VUE3教程 Bootstrap教程 SQL数据库教程 C语言教程 C++教程 Java教程 Python教程 Python3教程 C#教程
数码: 电脑笔记本显卡显示器固态硬盘硬盘耳机手机 iphone vivo oppo 小米华为单反装机图拉丁

-> Python知识库 -> python中的协程示例 -> 正文阅读

[Python知识库]python中的协程示例

1、参考:?https://yanbin.blog/how-flask-work-with-asyncio/#more-10368

2、先前使用queue.Queue，这个队列是自带锁机制，且其put，get方法可以使用阻塞，造成调用Flask的api接口发送socket消息时，有时能发，有时不能发的问题，后改为协程实现。

import asyncio

async def send_one_msg(self, msg):
	try:
		soc_bytes = self.get_pack_buf(msg)

		self.client.send(soc_bytes)
	except Exception as e:
		print("send_one_msg 发送失败：", str(e))

def async_send_on_msg(self, msg):
	try:
		try:
			loop = asyncio.get_event_loop()
		except RuntimeError as er:
			print(er.args[0], 'create a new EventLoop')
			loop = asyncio.new_event_loop()
		loop.run_until_complete(self.send_one_msg(msg))
		
		# python3.7才支持
        # asyncio.run(self.send_one_msg(msg))
	except Exception as e:
		print("async_send_on_msg 发送失败：", str(e))

3、感觉async， await与.net中的机制类似。