码迷,mamicode.com
首页 > 其他好文 > 详细

日志池

时间:2017-12-18 12:39:10      阅读:172      评论:0      收藏:0      [点我收藏+]

标签:gpo   最大消息   时间   pos   一个   网络   网络io   body   当前时间   

日志池

提供一个队列池,里面有多个队列,每个队列都可固定存放一定数量的消息。网络IO线程要给逻辑线程投递消息时,会从池中取一个空队列来使用,
直到将该队列填满后再放回池中换另一个空队列。而逻辑线程取消息时是从池中取一个有消息的队列来读取,处理完后清空队列再放回到池中。 
这样便使得只有在对队列容器进行操作时才需要加锁,而IO线程和逻辑线程在操作自己当前使用的队列时都不需要加锁,所以锁竞争的机会大大减少了。 
这里为每个队列设了个最大消息数,看来好像是打算只有当IO线程写满队列时才会将其放回到容器中换另一个队列。那这样有时也会出现IO线程未写满一 
个队列,而逻辑线程又没有数据可处理的情况,特别是当数据量很少时可能会很容易出现。

如何解决?
这个可以通过设置超时来处理, 如果当前时间-向队列放入第一个包的时间> 50 ms, 就将其放回到池中换另一个队列。

 

日志池

标签:gpo   最大消息   时间   pos   一个   网络   网络io   body   当前时间   

原文地址:http://www.cnblogs.com/hnxxcxg/p/8055981.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!