协程通信机制——Future,Channel与Pub/Sub
发布网友
共1个回答
热心网友
摘要：本文比较了几种常见的协程框架中的通信机制，着重介绍了VLCP中的Pub/Sub通信机制，提供一个直观的认识。
协程与通信：在现代异步IO框架中，调度的基本单位是协程。为充分利用协程的调度模型，选择一个方便的通信机制至关重要。应具备完成特定任务的功能，不同模型在实现方便程度上存在差异。
类比多线程的互斥区、信号量等：greenlet等模型通过模拟多线程中的互斥区和信号量，简化了使用，但存在缺点，如难以在协程模型中高效实现。
事件处理器：维护事件处理器列表，在事件发生时调用，实现通知功能。然而，对于协程模型，存在一些局限性。
Promise-Future模型：Promise和Future模型是Python3 asyncio框架中的通信模型，代表异步通信过程。发送方通过Promise发送消息，接收方使用Future随时获取结果或等待。
Future模型特点：适合简单的异步过程，但复杂系统中编写正确代码较为困难。
Channel模型：Go语言中统一的通信模型，解决Future一次性使用的。Channel允许写入和读取信号，信号遵循先进先出原则，支持缓冲区大小，能实现阻塞。
Channel模型特点：适合复杂系统，但管理Channel较为复杂。
Pub/Sub模型 - VLCP：VLCP使用Pub/Sub模型，结合前两种模型的优点，弥补缺点。通过发布者、订阅者机制实现通信，事件匹配高效，支持索引和自定义筛选，简化通信过程。
事件循环结构：VLCP事件循环包含调度器、匹配树、中心消息队列和Poller，管理协程注册和事件匹配，执行事件处理。
防止事件遗失：VLCP安全处理未被处理的事件，防止遗漏，确保每个事件得到正确处理。
阻塞式事件：通过设置Event的canignore属性实现Channel模型的阻塞效果，匹配事件后需设置canignore为True。
子队列：引入多队列结构，防止队列阻塞，允许优先级管理和事件轮询，支持精细控制。
控制流程：RoutineContainer提供了协程控制流程，简化复杂逻辑实现。
对接线程池：vlcp.utils.connector模块实现异步逻辑与线程池的集成，支持非协程库调用。
总结：VLCP的Pub/Sub模型适用于复杂异步逻辑设计，综合前模型优点，简化核心代码逻辑，易于实现复杂异步过程，尽管调度复杂度稍高，但业务代码清晰，可能产生性能优势。
