标签：
之前在设计消息队列的时候，用的双缓冲，保持一个读线程，一个写线程！！ 读线程对read_list进行操作，写线程对write_list进行操作，保持一个队列的完整行就ok！
比如如果想保持write_list一致，就是在插入操作的时候枷锁，在read_list为空的时候需要和write_list进行交换，也需要枷锁！！这样就保证了很少的线程冲突！！！当时的消息队列的双缓冲使用std::list进行设计！
第二个版本的消息队列，进行了很大程度上的改进，使用了三个缓冲队列，一个读队列，一个写队列，一个缓冲队列，三个队列分别用数组形式体现，枷锁只要保证缓冲队列一致既可，即写队列向缓冲队列提交数据的时候，需要枷锁，读队列再向缓冲队列交换数据的时候，需要枷锁！想比较于上面的方法，枷锁次数明显减少，并且使用数组的形式，较std::list更为高效！这个消息队列在原公司的双缓冲队列的基础之上，进行设计！
给出测试代码！和部分接口！
接口：
class DuplexList{public: DuplexList(int size = 1024); virtual ~DuplexList(void); virtual int append(CommonItem item); virtual int peek(CommonItem &item);protected: virtual int swap(CommonItem &item); virtual int submit();protected: CommonList *read_list_; CommonList *share_list_; CommonList *write_list_; Mutex _switch_mutex; int peek_index_;}; |
做了一下午的测试，没有问题，传递10w条消息大概使用20ms左右！这个性能可以了！
之前在语言的选择上面做了很长时间的犹豫，一些java的朋友劝我说，一个消息队列的错误，那么整个游戏就会崩溃！劝我使用java的集成结构！！ 不过最终我还是坚持了C++，底层代码使用C++,逻辑使用lua来编写！只是在AI的问题上面还有很多犹豫！
标签：
原文地址：http://www.cnblogs.com/shouce/p/5357722.html
