我们只管罕用体系自带的音讯行列（比方Linux的sys/msgqueue），那样移植性不是很强，我们愿望的音讯行列，在音讯打包和提取都是用的规范的C++数据结构，固然，你也能够用链表或许是FIFO，那样得先写个链表或许FIFO出来。
我比较懒，直接用的C++的STL的deque，即双端口行列，如许可靠性有保证，固然，速率能够没有本身写的链表快，然则没紧要，运用双端口行列还能够依据你本身的须要将数据插进去到行列头或许行列尾，如许在音讯有优先级的情况下照样有效的。
音讯行列的核心作用实在很简朴，一个或多个线程往一个行列背面堆数据，别的的一个线程从行列前面取数据处置惩罚，基础操纵也只要两个，一个发，一个收，所以，我们定义音讯行列基类为：
class CMsgQueue
{
public:
CMsgQueue(const char *pName=NULL);
~CMsgQueue();
//revice data from message queue
virtual bool recvMsg(unsigned int &m_msg_code,void *&p_msg)=0;
//send data to message queue
virtual bool sendMsg(unsigned int m_msg_code,void *p_msg)=0;
const char * getName(void) const {
return msg_queue_name;
}
private:
char *msg_queue_name;
};
然后记得在COperratingSystemFactory里加上建立音讯行列的要领：
class COperatingSystemFactory
{
public:
static COperatingSystem *newOperatingSystem();
static CCountingSem *newCountingSem(unsigned int init);
static CMutex *newMutex(const char *pName=NULL);
static CMsgQueue *newMsgQueue(const char *pName=NULL);
};
末了，从CMsgQueue继承一个CLinuxMsgQueue，然后把recvMsg和sendMsg完成吧，完成的时刻注重一下。
纯真的操纵双端口FIFO不可，我们愿望是吸收音讯的时刻假如没有音讯，线程壅塞在那边守候音讯直到有音讯到来才接着运转，所以，吸收音讯的时刻我们用了信号量，壅塞在信号量那边，发送音讯的时刻操纵完行列，发送一个信号量出去。
其次，关于行列的操纵，我们愿望是原子性的，不然一个正在收一个正在发就乱了，所以操纵行列的时刻我们用互斥锁来锁一下，保证基础的原子性。
对应到详细的顺序就是
1.为每一个音讯行列请求一个锁，一个信号量
CLinuxMsgQueue::CLinuxMsgQueue(const char *pName):
CMsgQueue(pName)
{
p_mutex=COperatingSystemFactory::newMutex("Msg Mutex");
p_sem=COperatingSystemFactory::newCountingSem(0);
}
吸收音讯的时刻：
bool CLinuxMsgQueue::recvMsg(unsigned int &m_msg_code,void *&p_msg)
{
bool result;
Elements queue_element;
p_sem->Get(); //经由过程信号量壅塞在这里，有音讯抵达了才接着往下走
p_mutex->Lock(); //锁定，保证原子性
//操纵行列
if (m_queue.empty()) {
p_mutex-> UnLock ();
return false;
}
queue_element = m_queue.front();
m_queue.pop_front();
m_msg_code = queue_element.msg_code;
p_msg = queue_element.p_message;
//操纵行列完毕
p_mutex->UnLock(); //消除锁定
return true;
}
发送的时刻也是相似的体式格局举行，如许，一个最简朴音讯行列就完成了。假如我们要运用音讯行列的话，很简朴，在main.cpp中
int main()
{
//起首，新建一个音讯行列
CMsgQueue *q=COperatingSystemFactory::newMsgQueue("B to A message Queue");
//新建两个线程，TestThread和TestThreadB都是从CThread继承下来的线程类
TestThread *a=new TestThread("A");
TestThreadB *b=new TestThreadB("B");
//将音讯行列放到两个线程实体的局部变量中
a->setMsgQueue(q);
b->setMsgQueue(q);
//启动线程
a->run();
b->run();
}
当要在mainloop中发送音讯的时刻，只须要挪用
p_msg_send->sendMsg(code, (void *)p_msg); //个中p_msg_send是b线程的局部变量，现实指向的是之前新建的音讯行列q
github地点：
https://github.com/wyh267/Cplusplus_Thread_Lib
写在背面的话：
固然，这个代码还异常不完整，全部代码量也没有若干行，在这里，我只是供应一个代码框架的要领，作为一个demo给人人参考，假如真的须要现实运用另有许多许多处所须要修正的，github上我的代码也不能在生产软件中现实运用，在现实的项目中，我也完成了一个没有任何第三方的线程库，比这个庞杂多了，还包含事宜处置惩罚，守候超时，音讯播送，音讯定阅等模块，而且能运转在linux,ecos等多个平台上，基础做到平台无关了，但由于种种缘由我也没办法将代码都公布出来，这里所说的这个框架只是项目中线程库提取出来的异常少的一部分，一样，也只是供应一种编程的设想头脑，背面的东西愿望人人各自有各自的挖掘和完美，或许你看了今后，会提出越发强大和简约的框架。
别的，github上的代码我会继承完美，将其他模块连续加上，假如人人感兴趣也能够跟我一起来完美，我只管不运用之前完成过的线程库的代码，防止不必要的贫苦。
以上就是C++ 多线程框架（3）：音讯行列的内容，更多相关内容请关注ki4网（www.ki4.cn）！
