1

我有 1 个SingleChronicleQueue通过 methodWriter 代理 API 附加了不同的消息。

我的阅读器处理程序处理“message1”,并为同一处理程序附加一条不同的消息“message2”,以通过不同的方法(message2())进行处理。

Flow is:
    Append: proxy appends message1 to Q
    Tailer: handler1 reads message1 and 
            appends using proxy message2 to same Q
    Tailer: handler1 reads message2

好的?

或者裁缝是否应该总是写到不同的“Out”队列并让它介于两者之间?

这种方法控制对共享状态的非锁定访问的原因。

4

1 回答 1

1

最简单的解决方案是为所有事件设置一个队列,并让读者忽略他们不关心的事件。

有更多的队列可能有很好的理由,但是,我会从一个开始,然后从那里开始。

注意:对于单个队列,tailer 将看到所有消息,即使是使用 tailer 编写的线程。

于 2018-11-09T13:39:34.593 回答