amphp priority emitter:带有优先级队列的AMP Emitter 源码

AMP优先发射器 具有优先消息的异步发射器在内存中的实现 为什么 AMP Emitter的实现由队列支持。 它涵盖了许多情况,但有时需要一个优先级队列。 例如,您正在为社交网络或Messenger创建机器人。 假设该机器人可以响应用户的命令并向其所有订户广播信息。 这两种消息具有不同的优先级。 必须尽快发送命令的响应以使UX保持响应,但广播消息可能要等待一段时间。 您可以围绕消息总线构建应用程序。 有一些将消息推送到总线的代码,还有一些将消息拉出并传输到社交网络API的代码。 您不能使用AMP随附的Emitter,因为在这种情况下,广播消息将阻止命令消息,因为AMP Emitter无法