多线程模拟实现发布-订阅(一)
2020-05-16 本文已影响0人
__晨风__
我们是模拟两个生产者,各自都往消息队列里推送消息,共计100条
再次模拟两个消费者,各自都开始消费消息
生产者1
生产者2
消费者1
消费者2
发布订阅测试类
缺点:每条消息都会新产生一个线程,这对于实际作业当中,系统因为线程数量过多而导致CPU
急剧升高,这里可以引入线程池来进行提交任务
我们是模拟两个生产者,各自都往消息队列里推送消息,共计100条
再次模拟两个消费者,各自都开始消费消息
生产者1
生产者2
消费者1
消费者2
发布订阅测试类
缺点:每条消息都会新产生一个线程,这对于实际作业当中,系统因为线程数量过多而导致CPU
急剧升高,这里可以引入线程池来进行提交任务