消息队列示例代码,C代码库,德仔网

代码语言
代码分类
【C】消息队列示例
作者:defddr / 发布于2014/11/13/ 708

	/*******************************************************************************
	* @file
	* @author def< qq group: 324164944 >
	* @blog http://www.cnblogs.com/itdef/
	* @brief
	/*******************************************************************************/
	
	#ifndef MSG_QUE_H__
	#define MSG_QUE_H__
	
	#include <process.h>
	#include <iostream>
	#include <string>
	#include <deque>
	#include "CLock.h"
	
	using namespace std;
	
	
	class CMsgQueue{
	private:
	 CLock threadLock;
	 CEvent threadEvent;
	 HANDLE hThread[2];
	 deque<string> dequeStringMsg;
	public:
	 CMsgQueue() {}
	 ~CMsgQueue() {
	 if(hThread[0] != INVALID_HANDLE_VALUE)
	 {
	 CloseHandle(hThread[0]);
	 hThread[0] = INVALID_HANDLE_VALUE;
	 }
	 if(hThread[1] != INVALID_HANDLE_VALUE)
	 {
	 CloseHandle(hThread[1]);
	 hThread[1] = INVALID_HANDLE_VALUE;
	 }
	 }
	
	 bool run() {
	 hThread[0] = (HANDLE)_beginthread(ThreadSendFunc,0,this);
	 hThread[1] = (HANDLE)_beginthread(ThreadRecvFunc,0,this);
	 if( hThread[0] == INVALID_HANDLE_VALUE || hThread[1] == INVALID_HANDLE_VALUE)
	 {
	 return false;
	 }
	 WaitForMultipleObjects(2,hThread,true,INFINITE);
	 return true;
	 }
	
	 static void ThreadSendFunc(PVOID arg);
	 static void ThreadRecvFunc(PVOID arg);
	
	 bool SendMsgWihtLock(const string& strMsg);
	 bool SendPriorityMsgWihtLock(const string& strMsg);
	 bool RecvMsgWihtLock(string& strMsg);
	};
	
	bool CMsgQueue::RecvMsgWihtLock(string& strMsg)
	{
	 bool bRet = false;
	
	 threadLock.Acquire();
	 if( !(dequeStringMsg.empty()))
	 {
	 strMsg = dequeStringMsg.front();
	 dequeStringMsg.pop_front();
	 bRet= true;
	 }else
	 {
	 bRet= false;
	 }
	 threadLock.Release();
	
	 return bRet;
	}
	
	bool CMsgQueue::SendMsgWihtLock(const string& strMsg)
	{
	 threadLock.Acquire();
	 dequeStringMsg.push_back(strMsg);
	 threadLock.Release();
	
	 return true;
	}
	
	bool CMsgQueue::SendPriorityMsgWihtLock(const string& strMsg)
	{
	 threadLock.Acquire();
	 dequeStringMsg.push_front(strMsg);
	 threadLock.Release();
	
	 return true;
	}
	
	
	
	void CMsgQueue::ThreadSendFunc(PVOID arg)
	{
	 CMsgQueue* p = (CMsgQueue*)arg;
	
	 p->SendMsgWihtLock("first in");
	 p->SendPriorityMsgWihtLock("second in but first");
	
	 return;
	}
	
	void CMsgQueue::ThreadRecvFunc(PVOID arg)
	{
	 CMsgQueue* p = (CMsgQueue*)arg;
	
	 while(1)
	 {
	
	 string strMsg;
	
	 if( true == p->RecvMsgWihtLock(strMsg))
	 cout << "recv: " << strMsg << endl;
	 Sleep(1000);
	 }
	
	
	
	 return;
	}
	
	
	
	
	
	#endif
试试其它关键字
　消息队列　
同语言下
可能有用的
defddr贡献的其它代码(6)