之前，多執行緒一些基本的東西，包括執行緒創建，互斥鎖，訊號量，我們都已經封裝，下面來看看訊息佇列
我們盡量少用系統自帶的訊息佇列（例如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);
};最後，從CMsginBsgue實現的時候注意一下。
單純的操作雙埠FIFO不行，我們希望是接收訊息的時候如果沒有訊息，線程阻塞在那裡等待訊息直到有訊息到來才接著運行，所以，接收訊息的時候我們用了信號量，阻塞在信號量那裡，發送訊息的時候操作完佇列，發送一個信號量出去。
其次，對於隊列的操作，我們希望是原子性的，不然一個正在收一個正在發就亂了，所以操作隊列的時候我們用互斥鎖來鎖一下，保證基本的原子性。
對應到具體的程序就是
1.為每個訊息隊列申請一個鎖，一個信號量
CLinuxMsgQueue::CLinuxMsgQueue(const char *pName):
CMsgQueue(pName)
{
p_mutex=COperatingSystemFactory::newMutex("Msg Mutex");
p_sem=COperatingSystemFactory::newCountingSem(0);
}也是類似的方式進行，這樣，一個最簡單訊息佇列就完成了。如果我們要使用訊息佇列的話，很簡單，在main.cpp中
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;
}當要在mainloop中發送訊息的時候，只需要呼叫
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();
}github位址：
另外，github上的程式碼我會繼續完善，將其他模組陸續加上，如果大家有興趣也可以跟我一起來完善，我盡量不使用之前實現過的線程庫的程式碼，避免不必要的麻煩。
以上就是C++ 多執行緒框架（3）：訊息佇列的內容，更多相關內容請關注PHP中文網（m.sbmmt.com）！
