加入收藏 | 设为首页 | 会员中心 | 我要投稿 李大同 （https://www.lidatong.com.cn/）- 科技、建站、经验、云计算、5G、大数据,站长网!
当前位置： 首页 > 百科 > 正文

【Cocos2d-x】C++自定义线程安全消息管理

发布时间：2020-12-14 19:29:39 所属栏目：百科 来源：网络整理
导读：【Cocos2d-x】C++自定义线程安全消息管理 一、背景 由于Cocos2d-x本身的NotificationCenter是没有进行线程安全处理的，所以当我们在Cocos2d-x里面使用多线程进行消息同步的时候，会出现问题。那么为了解决这个问题，我们只需要进行线程安全锁定即可。 为了不

【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( removeObserverByName( removeAllObservers(cocos2d::Ref*target);
protected :
XMessage*getMessageByName( std::string&msgName) ;
private :
//messagecontainer
cocos2d::Vector<XMessage*>_msgContainer;
};
CC_DLLXMessage: cocos2d::Ref
{
:
XMessage( ~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

实现文件：

43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
#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( :_msgName(msgName),_target(target),_selector(selector),_msgContent(msgContent)
{
}
XMessage::~XMessage()
{
}
XMessage::handerMessage(cocos2d::Ref*msgContent)
{
(_target)
{
(msgContent){
(_target->*_selector)(msgContent);
} else {
(_target->*_selector)(msgContent);
}
}
}

（编辑：李大同）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!
    相关内容
      推荐文章
        站长推荐
        热点阅读

          【免责声明】本站内容转载自互联网，其发布内容言论不代表本站观点，如果其链接、内容的侵犯您的权益，烦请提交相关链接至邮箱bqsm@foxmail.com我们将及时予以处理。

          建议您使用1920×1080分辨率、谷歌浏览器Google Chrome、Microsoft Edge以获得本站的最佳浏览效果

          Copygight © 2008-2022 https://www.lidatong.com.cn/ All Rights Reserved. 李大同