队列-生产者消费者模式

我们可以将Domain视为MQ队列,每个node为一个队列消息,检查Domain的变化来获取队列消息。

❏ Sender:是一个队列发送者,它发送消息的实现是在queue上创建一个匿名节点来存放消息

pl.create(queue, (Serializable)obj); 

❏ Receiver:是一个队列接收者,他轮循queue上有没有最新消息,有就取出,并删除该节点,注意它是每次获取第一个消息,这样保证消息读取的顺序

 

原文地址:https://www.cnblogs.com/muzinan110/p/11052142.html