实现具有优先订阅者和并发修改的事件总线

Question

我的应用程序有几个部分需要对从其他地方触发的事件做出反应，所以我首先想到的是事件总线。这些是我看到的要求:

• 订阅者方法应该是类型安全的
• 实现接口（如订阅者

我可能需要的奖金要求：

• 在处理事件时注册新订阅者
• 在接收事件时发送事件。在继续当前任务之前，这些将被同步处理
• 将当前没有订阅者的事件“池”并稍后手动处理它们的选项（可能通过传递消费者）。

除了优先级之外，Guava Eventbus可能做了大部分这些事情。我可以使用TreeSet创建一个简单的优先级订阅者队列，但我不知道如何将其集成到Guava中，我不知道我是否想仅为总线依赖整个库。

另外，我可能需要一个 CopyOnWriteArrayList 来处理并发内容（在迭代时添加/删除），但我不知道性能的影响。在这一点上，一次可能不会超过10-15个订阅者。




Answer 1

正常事件并不是被设计成可变的。你应该坚持使用不可变的数据。此外，用户不希望在某个顺序内被呼叫或与另一个顺序交互。对于您的用例，您可以为每个优先级构建不同的事件总线。用户可以将修改的事件的副本移交给下一个优先级总线。