首页 > 代码库 > cocos2dx C++自定义线程安全消息管理
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<XMessage*> _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<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* 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
cocos2dx C++自定义线程安全消息管理
声明:以上内容来自用户投稿及互联网公开渠道收集整理发布,本网站不拥有所有权,未作人工编辑处理,也不承担相关法律责任,若内容有误或涉及侵权可进行投诉: 投诉/举报 工作人员会在5个工作日内联系你,一经查实,本站将立刻删除涉嫌侵权内容。