学步园

 为了携带更多参数在线程间调用过程，我最近模仿windows的MFC命令机制，写了一个简单的事件机制  

分为事件消息接收器，事件转发器，事件处理器等。主要代码如下

1. JrEvent.h

#pragma once</p> <p>#define EVENT_MSG WM_USER + 0X100<br /> typedef UINT EVENT_CODE;<br /> typedef HANDLE HEVENT;</p> <p>struct EventParam<br /> {<br /> void* PInParamBuf;//输入<br /> void* pOutParamBuf; //输出<br /> bool bSuccess;<br /> bool bSyncCall;<br /> HEVENT hNotifyEvent;//调用完成通知事件(用于异步调用）<br /> bool bCalleeReleaseMem; //指示是否由被调用者释放内存，具体是否释放，可综合设计，由具体的事件处理器考虑</p> <p> EventParam()<br /> {<br /> PInParamBuf = NULL;<br /> pOutParamBuf = NULL;<br /> bSuccess = false;<br /> bSyncCall = true;<br /> hNotifyEvent = NULL;<br /> bCalleeReleaseMem = false;<br /> };<br /> };</p> <p>typedef EventParam *PEventParam;</p> <p>class CJrEventSink;<br /> typedef void (CJrEventSink::*JMC_EVENTFUNC)(PEventParam);</p> <p>struct JMC_EVENTMAP_ENTRY<br /> {<br /> UINT nEventCode;<br /> JMC_EVENTFUNC lpEventFunc;<br /> };</p> <p>struct JMC_EVENTMAP<br /> {<br /> const JMC_EVENTMAP* (PASCAL* pfnGetBaseMap)();<br /> const JMC_EVENTMAP_ENTRY* lpEntries;<br /> };</p> <p>#define DECLARE_JMC_EVENT_MAP() /<br /> private: /<br /> static const JMC_EVENTMAP_ENTRY _eventEntries[]; /<br /> protected: /<br /> static const JMC_EVENTMAP eventMap; /<br /> static const JMC_EVENTMAP* PASCAL GetThisEventMap(); /<br /> virtual const JMC_EVENTMAP* GetEventMap() const; </p> <p>#define BEGIN_JMC_EVENT_MAP(theClass, baseClass) /<br /> const JMC_EVENTMAP* PASCAL theClass::GetThisEventMap()/<br /> { return &theClass::eventMap; } /<br /> const JMC_EVENTMAP* theClass::GetEventMap() const /<br /> { return &eventMap; } /<br /> const JMC_EVENTMAP theClass::eventMap = /<br /> { &(baseClass::GetThisEventMap), theClass::_eventEntries,};/<br /> const JMC_EVENTMAP_ENTRY theClass::_eventEntries[] = /<br /> {</p> <p>#define END_JMC_EVENT_MAP() /<br /> {0, NULL }, /<br /> };</p> <p>#define ON_JMC_EVENT(id, memberFxn)/<br /> { (EVENT_CODE)id, static_cast<JMC_EVENTFUNC>(memberFxn)},<br />

2. receicver, router.h

#include "JrEvent.h"<br /> #include <list></p> <p>class JRTL_API CJrEventRouterWnd : public CWnd<br /> {<br /> DECLARE_DYNAMIC(CJrEventRouterWnd)<br /> public:<br /> CJrEventRouterWnd(){}<br /> virtual ~CJrEventRouterWnd(){}<br /> virtual void CreateEventSinks() = 0;<br /> std::list<CJrEventSink*> m_sinks;<br /> protected:<br /> DECLARE_MESSAGE_MAP();<br /> afx_msg LRESULT OnEventMsg(WPARAM wp_, LPARAM lp_);<br /> };</p> <p>class JRTL_API CJrEventReceiver<br /> {<br /> public:<br /> CJrEventReceiver(void);<br /> virtual ~CJrEventReceiver(void);</p> <p> LRESULT SynEventProcess(EVENT_CODE nCode_, PEventParam pParam_);<br /> BOOL AsynEventProcess(EVENT_CODE nCode_, PEventParam pParam_);</p> <p>protected:<br /> virtual CJrEventRouterWnd* GetEventRouterWnd() = 0;<br /> };

3. receiver, router.cpp

#include "StdAfx.h"<br /> #include "JrEventReceiver.h"</p> <p>IMPLEMENT_DYNAMIC(CJrEventRouterWnd, CWnd)</p> <p>BEGIN_MESSAGE_MAP(CJrEventRouterWnd, CWnd)<br /> ON_MESSAGE(EVENT_MSG, OnEventMsg)<br /> END_MESSAGE_MAP()</p> <p>LRESULT CJrEventRouterWnd::OnEventMsg(WPARAM wp_, LPARAM lp_)<br /> {<br /> bool bFind = false;<br /> PEventParam pEP = (PEventParam)lp_;<br /> for (std::list<CJrEventSink*>::iterator _it = m_sinks.begin(); _it != m_sinks.end(); ++_it)<br /> {<br /> if ((*_it)->OnEventMsg((EVENT_CODE)wp_, pEP))<br /> {<br /> if (pEP->hNotifyEvent)<br /> {<br /> //...<br /> }</p> <p> bFind = true;</p> <p> }</p> <p> }</p> <p> if (pEP->bCalleeReleaseMem)<br /> {<br /> //...<br /> }</p> <p> return bFind ? 0; -1;<br /> }</p> <p>CJrEventReceiver::CJrEventReceiver(void)<br /> {<br /> }</p> <p>CJrEventReceiver::~CJrEventReceiver(void)<br /> {<br /> }</p> <p>LRESULT CJrEventReceiver::SynEventProcess(EVENT_CODE nCode_, PEventParam pParam_)<br /> {<br /> CJrEventRouterWnd* _pRouter = GetEventRouterWnd();<br /> if (!_pRouter || !_pRouter->GetSafeHwnd())<br /> {<br /> if (pParam->hNotifyEvent)<br /> {<br /> //...<br /> }</p> <p> if (pParam->bCalleeReleaseMem)<br /> {<br /> //...<br /> }<br /> return -1;<br /> }</p> <p> return _pRouter->SendMessage(EVENT_MSG, nCode_, (LPARAM)pParam_);<br /> }</p> <p>BOOL CJrEventReceiver::AsynEventProcess(EVENT_CODE nCode_, PEventParam pParam_)<br /> {<br /> CJrEventRouterWnd* _pRouter = GetEventRouterWnd();<br /> if (!_pRouter || !_pRouter->GetSafeHwnd())<br /> {<br /> if (pParam->hNotifyEvent)<br /> {<br /> //...<br /> }<br /> if (bCalleeReleaseMem)<br /> {<br /> //...<br /> }<br /> return FALSE;<br /> }</p> <p> return _pRouter->PostMessage(EVENT_MSG, nCode_, (LPARAM)pParam_);<br /> }<br />

4. sink基类.h

 #pragma once</p> <p>#include "JRtl.h"<br /> #include "JrEvent.h"</p> <p>class JRTL_API CJrEventSink<br /> {<br /> public:</p> <p> CJrEventSink(void);<br /> virtual ~CJrEventSink(void);<br /> virtual BOOL OnEventMsg(EVENT_CODE nEventCode_, EventParam* pEventParam_);</p> <p> DECLARE_JMC_EVENT_MAP()<br /> };

5. sink基类.cpp

#include "StdAfx.h"<br /> #include "JrEventSink.h"</p> <p>const JMC_EVENTMAP CJrEventSink::eventMap =<br /> {<br /> NULL, &CJrEventSink::_eventEntries[0],<br /> };</p> <p>const JMC_EVENTMAP_ENTRY CJrEventSink::_eventEntries[] =<br /> {<br /> { 0, NULL } // nothing here<br /> };</p> <p>CJrEventSink::CJrEventSink(void)<br /> {<br /> }</p> <p>CJrEventSink::~CJrEventSink(void)<br /> {<br /> }</p> <p>const JMC_EVENTMAP* CJrEventSink::GetEventMap() const<br /> {<br /> return &eventMap;<br /> }</p> <p>const JMC_EVENTMAP* PASCAL CJrEventSink::GetThisEventMap()<br /> {<br /> return &eventMap;<br /> }</p> <p>BOOL CJrEventSink::OnEventMsg(EVENT_CODE nEventCode_, EventParam* pEventParam_)<br /> {<br /> for (const JMC_EVENTMAP* pMap = GetEventMap(); pMap != NULL; pMap = (*pMap->pfnGetBaseMap)())<br /> {<br /> const JMC_EVENTMAP_ENTRY* pEntry = pMap->lpEntries;<br /> while (pEntry->nEventCode)<br /> {<br /> if (nEventCode_ == pEntry->nEventCode)<br /> {<br /> if (!pEntry->lpEventFunc)<br /> {<br /> ASSERT(FALSE);<br /> return FALSE;<br /> }</p> <p> (this->*(pEntry->lpEventFunc))(pEventParam_); //???<br /> return TRUE;<br /> }</p> <p> pEntry++;<br /> }</p> <p> if (NULL == (pMap->pfnGetBaseMap))<br /> return FALSE;<br /> }</p> <p> return FALSE;<br /> }<br />

6. 具体sink类

class CMySink : public CJrEventSink<br /> {<br /> public:<br /> CMySink(void);<br /> public:<br /> virtual ~CMySink(void);</p> <p>protected:</p> <p> DECLARE_JMC_EVENT_MAP()<br /> void OnMyEvent(PEventParam pParam_);</p> <p>};</p> <p>//.CPP<br /> BEGIN_JMC_EVENT_MAP(CMySink, CJrEventSink)<br /> ON_JMC_EVENT(EVENT_XXX, &CMySink::OnMyEvent)<br /> END_JMC_EVENT_MAP()</p> <p>CMySink::CMySink(void)<br /> {<br /> }</p> <p>CMySink::~CMySink(void)<br /> {<br /> }</p> <p>void CMySink::OnMyEvent(PEventParam pParam_)<br /> {<br /> TRACE(_T("onMYEVENT Not Implement/n"));<br /> }