cocos2d-x 3.2线程安全的消息中心

本文章参考了某个博友的文章，具体的记不清楚了，望见谅！
//

// MsgManager.h

// MsgManager
//
// Created by sky on 14-11-21.
//
// 线程安全的消息中心

#ifndef __MsgManager__MsgManager__
#define __MsgManager__MsgManager__

#include <stdio.h>
#include "cocos2d.h"
USING_NS_CC;

// 消息体
class CC_DLL Message : public Ref
{
public :
Message( const std::string &msgName,Ref* target,SEL_CallFuncO selector,Ref* msgContent);
virtual ~Message();
void handerMessage( Ref *msgContent);
CC_SYNTHESIZE_READONLY ( std :: string , m_msgName ,MessageName);
CC_SYNTHESIZE_READONLY ( Ref *, m_target ,Target);
CC_SYNTHESIZE_READONLY ( SEL_CallFuncO , m_selector ,Selector);
CC_SYNTHESIZE_READONLY ( Ref *, m_msgContent ,MessageContent); //function args
};


// 消息管理
class CC_DLL MsgManager: public Ref
{
public :
MsgManager();

virtual ~MsgManager();

static MsgManager * getInstance();

// 多个对象可以监听同一个名字的消息
bool addObserver( const std :: string &msgName, Ref *target, SEL_CallFuncO selector, Ref * msgContent= nullptr );

void postMessage( const std :: string & msgName);

void postMessage( const std :: string & msgName, Ref *msgContent);

// 如果 target 为空则移除所有名字为 msgName 的消息
void removeObserverByName( const std :: string & msgName, Ref *target= nullptr );

// 移除一个对象的所有监听
void removeAllObserver( Ref * target);

protected :
Message * getMessageByNameAndTarget( const std :: string &msgName, Ref * target) const ;

private :
Vector < Message *> m_msgContainer;
};


#endif /* defined(__MsgManager__MsgManager__) */

//
// MsgManager.cpp
// MsgManager
//
// Created by sky on 14-11-21.
//
//

#include "MsgManager.h"

#pragma mark-- 消息体
Message::Message( const std::string &msgName,Ref* msgContent):m_msgName(msgName),
m_target(target),
m_selector(selector),
m_msgContent(msgContent)

{
}
Message::~Message()
{
}

void Message::handerMessage(cocos2d::Ref *msgContent)
{
if (m_target)
{
(m_target ->* m_selector)(msgContent);
}
}

#pragma mark-- 消息管理
static MsgManager* instance = nullptr ;
std::mutex containerMutex;

MsgManager::MsgManager()
{
}
MsgManager::~MsgManager()
{
m_msgContainer.clear();
}

MsgManager* MsgManager::getInstance()
{
if (!instance)
{
instance = new MsgManager();
}
return instance;
}

bool MsgManager::addObserver( const std::string &msgName,cocos2d::Ref *target,Ref *msgContent)
{
std::lock_guard<std::mutex> ul(containerMutex);

if (!getMessageByNameAndTarget(msgName,target))
{
auto msg = new Message(msgName,target,selector,msgContent);
if (!msg)
{
return false ;
CC_SAFE_DELETE(msg);
}
msg -> autorelease();
m_msgContainer.pushBack(msg);
CCLOG( "msgCount:%lu" ,m_msgContainer.size());

return true ;
}
return false ;
}

void MsgManager::postMessage( const std::string &msgName,cocos2d::Ref *msgContent)
{
std::lock_guard<std::mutex> ul(containerMutex);
for ( auto &msg : m_msgContainer)
{
if (msgName==msg->getMessageName())
{
msg -> handerMessage(msgContent);
}
}
}

void MsgManager::postMessage( const std::string &msgName)
{
postMessage(msgName, nullptr );
}

Message* MsgManager::getMessageByNameAndTarget( const std::string &msgName,cocos2d::Ref *target) const
{
for ( auto &msg : m_msgContainer)
{
if (msgName==msg->getMessageName() && target==msg->getTarget())
{
return msg;
}
}
return nullptr ;
}

void MsgManager::removeObserverByName( const std::string &msgName,Ref *target)
{
std::lock_guard<std::mutex> ui(containerMutex);
for ( auto &msg : m_msgContainer)
{
if (msgName == msg->getMessageName() && (target==msg->getTarget()||!target))
{
m_msgContainer.eraseObject(msg, true ); //?
}
}
}

void MsgManager::removeAllObserver(cocos2d::Ref *target)
{
std::lock_guard<std::mutex> ul(containerMutex);
for ( auto &msg : m_msgContainer)
{
if (target==msg->getTarget())
{
m_msgContainer.eraseObject(msg, true ); } } }