cocos2dx C++自定義線程安全消息管理

一、背景

由於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 _msgContainer; 
};
class CC_DLL XMessage: public cocos2d::Ref
{
public:
	XMessage(const std::string &msgName,cocos2d::Ref* target,
		cocos2d::SEL_CallFuncO selector,cocos2d::Ref* msgContent);
	~XMessage();
	void handerMessage(cocos2d::Ref* msgContent);
CC_SYNTHESIZE_READONLY(std::string,_msgName,MessageName);//message name
CC_SYNTHESIZE_READONLY(cocos2d::Ref*,_target,Target);   //target
CC_SYNTHESIZE_READONLY(cocos2d::SEL_CallFuncO,_selector,Selector);//function
CC_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* target,cocos2d::SEL_CallFuncO selector,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 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 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 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 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* target,
				   cocos2d::SEL_CallFuncO selector,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