发布网友 发布时间:2022-04-21 18:29
我来回答
共1个回答
热心网友 时间:2023-04-30 22:23
第一个你为什么不在生产者线程接收消息的时候就区分是为那个消费者呢?这样就没有必要将所有消息装在一个队列中。应该是每人一个的!这样只需要多线程处理就自己队列中的消息就好了。消息队列在JDK5以后已经加入的集合框架中了,可以直接使用。例如,可以使用ArrayBlockingQueue或者LinkedBlockingQueue根据读写效率合理选择就好了。