【Cocos2d-x】C++自定义线程安全消息管理
一、背景
由于Cocos2d-x本身的NotificationCenter是没有进行线程安全处理的，所以当我们在Cocos2d-x里面使用多线程进行消息同步的时候，会出现问题。那么为了解决这个问题，我们只需要进行线程安全锁定即可。
为了不修改源码，我模仿NotificationCenter，自定义了一个消息管理。
二、思路
首先，我们定义一个消息体的数据类型Message。他里面存储有消息名称Name,消息处理函数，消息目标，消息内容。
然后，我们定义一个消息管理类。他里面有消息容器。去容纳每一个消息。管理类对外暴漏的接口只有添加消息和发送消息。具体内容需要自己实现。
最后，将消息容器每次操作加锁即可。一个可以重复利用的，多线消息处理机制就完成了。
三、代码
头文件：
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
|
/**************************************************************
*Copyright(c)2014-11-12byreal.Xm
*BlogAddress:http://blog.csdn.net/q229827701
*Email:229827701@qq.com
**************************************************************/
#ifndef__XMESSAGE__H
#define__XMESSAGE__H
#include"cocos2d.h"
class
XMessage;
CC_DLLMessageMsg:
public
cocos2d::Ref
{
:
MessageMsg();
virtual
~MessageMsg();
static
MessageMsg*getInstance();
bool
addObserver(
const
std::string&msgName,cocos2d::Ref*target,
cocos2d::SEL_CallFuncOselector,cocos2d::Ref*msgContent=nullptr);
postMessage(
protected
:
XMessage*getMessageByName(
std::string&msgName)
;
private
:
//messagecontainer
cocos2d::Vector<XMessage*>_msgContainer;
};
CC_DLLXMessage:
cocos2d::Ref
{
:
XMessage(
void
handerMessage(cocos2d::Ref*msgContent);
CC_SYNTHESIZE_READONLY(std::string,_msgName,MessageName);
//messagename
CC_SYNTHESIZE_READONLY(cocos2d::Ref*,_target,Target);
//target
CC_SYNTHESIZE_READONLY(cocos2d::SEL_CallFuncO,_selector,Selector);
//function
//functionargs
};
#endif//!_XMESSAGE_H
|
实现文件：
#include"XMessageManger.h"
std::mutex_ContainerMutex;
MessageMsg*_Manager=nullptr;
MessageMsg::MessageMsg()
{
}
MessageMsg::~MessageMsg()
{
_msgContainer.clear();
}
MessageMsg*MessageMsg::getInstance()
{
if
(!_Manager)
{
_Manager=
new
MessageMsg;
}
return
_Manager;
}
MessageMsg::addObserver(
/*=nullptr*/
)
{
(!getMessageByName(msgName))
{
automsg=
XMessage(msgName,target,selector,msgContent);
IF_NULL_RETURN_FALSE(msg);
msg->autorelease();
std::lock_guard<std::mutex>ul(_ContainerMutex);
_msgContainer.pushBack(msg);
return
true
;
}
false
;
}
MessageMsg::postMessage(
automsg=getMessageByName(msgName);
(msg)
{
msg->handerMessage(msgContent);
;
}
;
}
XMessage*MessageMsg::getMessageByName(
const
{
std::lock_guard<std::mutex>ul(_ContainerMutex);
for
(auto&msg:_msgContainer)
{
(msgName==msg->getMessageName())
{
msg;
}
}
nullptr;
}
MessageMsg::removeObserverByName(
)
{
std::lock_guard<std::mutex>ul(_ContainerMutex);
(auto&msg:_msgContainer)
{
(msgName==msg->getMessageName()
&&(target==msg->getTarget()||!target))
{
_msgContainer.eraSEObject(msg,
);
;
}
}
;
}
MessageMsg::removeAllObservers(cocos2d::Ref*target)
{
std::lock_guard<std::mutex>ul(_ContainerMutex);
(auto&msg:_msgContainer)
{
(target==msg->getTarget())
{
);
;
}
}
;
}
//////////////////////////////////////////////////////////////////////////
///XMessageClass
/////////////////////////////////////////////////////////////////////////
XMessage::XMessage(
{
}
XMessage::~XMessage()
{
}
XMessage::handerMessage(cocos2d::Ref*msgContent)
{
(_target)
{
(msgContent){
(_target->*_selector)(msgContent);
}
else
{
(_target->*_selector)(msgContent);
}
}
}
|
