cocos2dx C++自定义线程安全消息管理

概述一、背景 由于cocos2dx本身的NotificationCenter是没有进行线程安全处理的，所以当我们在cocos2dx里面使用多线程进行消息同步的时候， 会出现问题。那么为了解决这个问题，我们只需要进行线程安全锁定即可。        为了不修改源码，我模仿NotificationCenter，自定义了一个消息管理。 二、思路 首先，我们定义一个消息体的数据类型 Message。他里面存储 一、背景

由于cocos2dx本身的NotificationCenter是没有进行线程安全处理的，所以当我们在cocos2dx里面使用多线程进行消息同步的时候，

会出现问题。那么为了解决这个问题，我们只需要进行线程安全锁定即可。

为了不修改源码，我模仿NotificationCenter，自定义了一个消息管理。

二、思路 首先，我们定义一个消息体的数据类型 Message。他里面存储有消息名称name,消息处理函数，消息目标，消息内容。
然后，我们定义一个消息管理类。他里面有消息容器。去容纳每一个消息。 管理类对外暴漏的接口只有添加消息和发送消息。具体内容需要自己实现。 最后，将消息容器每次 *** 作加锁即可。一个可以重复利用的，多线消息处理机制就完成了。
三、代码 头文件：

/************************************************************** * copyright (c) 2014-11-12 by real.Xm   * Blog Address:	http://blog.csdn.net/q229827701 * Email: 229827701@qq.com **************************************************************/#ifndef __XMESSAGE__H#define __XMESSAGE__H#include "cocos2d.h"class XMessage;class CC_DLL MessageMsg : public cocos2d::Ref{public:	MessageMsg();	virtual ~MessageMsg();	static MessageMsg* getInstance();	bool addobserver(const std::string &msgname,cocos2d::Ref* target,cocos2d::SEL_CallFuncO selector,cocos2d::Ref* msgContent = nullptr);	bool postMessage(const std::string &msgname,cocos2d::Ref* msgContent);	bool removeObserverByname(const std::string &msgname,cocos2d::Ref* target = nullptr);	bool removeAllObservers(cocos2d::Ref* target);protected: 	XMessage* getMessageByname(const std::string &msgname) const;private:	//message container	cocos2d::Vector<XMessage*> _msgContainer; };class CC_DLL XMessage: public cocos2d::Ref{public:	XMessage(const std::string &msgname,cocos2d::Ref* msgContent);	~XMessage();	voID handerMessage(cocos2d::Ref* msgContent);CC_SYNTHESIZE_Readonly(std::string,_msgname,Messagename);//message nameCC_SYNTHESIZE_Readonly(cocos2d::Ref*,_target,Target);   //targetCC_SYNTHESIZE_Readonly(cocos2d::SEL_CallFuncO,_selector,Selector);//functionCC_SYNTHESIZE_Readonly(cocos2d::Ref*,_msgContent,MessageConent);//function args};#endif // !_XMESSAGE_H

实现文件

#include "XMessagemanger.h"std::mutex _ContainerMutex;static MessageMsg* _Manager = nullptr;MessageMsg::MessageMsg(){}MessageMsg::~MessageMsg(){	_msgContainer.clear();}MessageMsg* MessageMsg::getInstance(){	if (!_Manager)	{		_Manager = new MessageMsg;	}	return _Manager;}bool MessageMsg::addobserver( const std::string &msgname,cocos2d::Ref* msgContent /*= nullptr*/ ){	if (!getMessageByname(msgname))	{		auto msg = new XMessage(msgname,target,selector,msgContent);		IF_NulL_RETURN_FALSE(msg);		msg->autorelease();		std::lock_guard<std::mutex> ul(_ContainerMutex);		_msgContainer.pushBack(msg);		return true;	}	return false;}bool MessageMsg::postMessage( const std::string &msgname,cocos2d::Ref* msgContent ){	auto msg = getMessageByname(msgname);	if (msg)	{		msg->handerMessage(msgContent);		return true;	}	return false;}XMessage* MessageMsg::getMessageByname( const std::string &msgname ) const{	std::lock_guard<std::mutex> ul(_ContainerMutex);	for (auto &msg : _msgContainer)	{		if (msgname == msg->getMessagename())		{			return msg;		}	}	return nullptr;}bool MessageMsg::removeObserverByname( const std::string &msgname,cocos2d::Ref* target /*= nullptr*/ ){	std::lock_guard<std::mutex> ul(_ContainerMutex);	for (auto &msg : _msgContainer)	{		if (msgname == msg->getMessagename()			&&(target == msg->getTarget()||!target))		{			_msgContainer.eraSEObject(msg,true);			return true;		}	}	return false;}bool MessageMsg::removeAllObservers( cocos2d::Ref* target ){	std::lock_guard<std::mutex> ul(_ContainerMutex);	for (auto &msg : _msgContainer)	{		if (target == msg->getTarget())		{			_msgContainer.eraSEObject(msg,true);			return true;		}	}	return false;}/////////////////////////////////////////////////////////////////////////////   XMessage Class/////////////////////////////////////////////////////////////////////////XMessage::XMessage( const std::string &msgname,cocos2d::Ref* msgContent )				   :_msgname(msgname),_target(target),_selector(selector),_msgContent(msgContent){}XMessage::~XMessage(){}voID XMessage::handerMessage( cocos2d::Ref* msgContent ){	if (_target)	{		if (msgContent) {			(_target->*_selector)(msgContent);		} else {			(_target->*_selector)(msgContent);		}	}}

四、申明 本文原创，为尊重原创，转载时请注明出处。 http://blog.csdn.net/q229827701/article/details/41042147 总结

以上是内存溢出为你收集整理的cocos2dx C++自定义线程安全消息管理全部内容，希望文章能够帮你解决cocos2dx C++自定义线程安全消息管理所遇到的程序开发问题。

如果觉得内存溢出网站内容还不错，欢迎将内存溢出网站推荐给程序员好友。