【玩转cocos2d-x之二十二】多线程和同步02-售票

发布时间：2020-12-14 14:16:36 所属栏目：百科来源：网络整理

导读：原创作品，转载请标明： http://www.jb51.cc/article/p-ntfjuwne-ep.html pthread有很多不同应用，官网都有相应的API解释和Sample，这里不再重复，本文主要介绍一个cocos2d-x多线程和同步示例。 1.售票孙鑫老师的C++和Java多线程售票一直让我念念不忘，好

原创作品，转载请标明：http://www.52php.cn/article/p-ntfjuwne-ep.html

pthread有很多不同应用，官网都有相应的API解释和Sample，这里不再重复，本文主要介绍一个cocos2d-x多线程和同步示例。

1.售票

孙鑫老师的C++和Java多线程售票一直让我念念不忘，好吧，这里用cocos2d-x和pthread实现一个吧。总共有100张火车票，有2个售票点A和B再售票，当票卖完了就结束了。我们知道当程序一开始进程就会创建一个主线程，所以可以在主线程基础上再创建2个线程A和B，再线程A和B中分别售票，当票数为0的时候，结束线程A和B。

2.多线程售票

[cpp] 
   view plain 
   copy 
    
   
 //TestLayer.h
 classCTestLayer:
 publicCCLayer
 {
public:
 CTestLayer(void);
 ~CTestLayer(void);
 
 CREATE_FUNC(CTestLayer);
virtualboolinit();
 
 pthread_tsellA_pid,sellB_pid;//线程id
staticinttickets;//票数
staticvoid*threadA(void*p);//线程A回调
void*threadB(//线程B回调
 };
 //TestLayer.cpp
 #include"TestLayer.h"
 intCTestLayer::tickets=100;//初始化票数100
 CTestLayer::CTestLayer(void)
 {
 }
 CTestLayer::~CTestLayer(void)
 }
boolCTestLayer::init()
boolbRet=false;
do
 CC_BREAK_IF(!CCLayer::init());
 pthread_create(&sellA_pid,NULL,threadA,0);//创建线程A
 pthread_create(&sellB_pid,threadB,0); background-color:inherit">//创建线程B
 bRet=true;
 }while(0);
returnbRet;
void*CTestLayer::threadA(void*p)
while(true)
if(tickets>0)
 CCLog("ASell%d",tickets--);//输出售票，每次减1
else{
break;
returnNULL;
void*CTestLayer::threadB(void*p)
true)
if(tickets>0)
 CCLog("BSell%d",tickets--);
else
 }

代码很简单，不多说了。我们来看一下输出，会发现有很多不可思议的现象出现，因为每个人每次运行的结果都不一样，所以这里不贴结果了，不可思议的现象可能有：

（1）同一张票卖了2次。

（2）后面的票比前面的票先卖出去。

（3）第0张票竟然也可以卖。（这算站票么。。。）

原因不多解释了，时间片的问题，不明白的Google之。如果你觉得不会有这么巧，那么在打印结果前加上这么一句：

copy 
    
   

Sleep(100);

人为干扰线程的运行，增大出错几率。结果可能会是这样：

copy 
    
   

ASell36

BSell36//卖2次了
ASell35
BSell34
ASell33
BSell32
ASell30//提早卖了
BSell31
BSell28
ASell29
ASell27
BSell26
ASell25
BSell24
ASell23
BSell22
ASell21
BSell20
ASell19
BSell18
ASell17
BSell16
ASell15
BSell14
ASell13
BSell12
ASell11
BSell10
ASell9
BSell8
ASell7
BSell6
ASell5
BSell4
ASell3
BSell2
ASell1
BSell0//站票。。。

3.利用互斥对象同步数据

这个问题主要是因为一个线程执行到一半的时候，时间片的切换导致另一个线程修改了同一个数据，当再次切换会原来线程并继续往下运行的时候，数据由于被修改了导致结果出错。所以我们要做的就是保证这个线程完全执行完，所以对线程加锁是个不错的注意，互斥对象mutex就是这个锁。

3.1.初始化

在cpp外分配空间：

copy 
    
   

pthread_mutex_tCTestLayer::mutex;//mutex是静态成员变量

在init中初始化，动态初始化：

copy 
    
   

pthread_mutex_init(&mutex,NULL);

3.2.加锁和解锁

以线程A为例：

copy 
    
   

pthread_mutex_lock(&mutex);//加锁

Sleep(100);
pthread_mutex_unlock(&mutex);//解锁
else{
pthread_mutex_unlock(&mutex);//解锁
}

3.3.释放

在当前层的析构函数中：

copy 
    
   

pthread_mutex_destroy(&mutex);//前提要保证是解锁状态，否则会返回16的错误，释放失败

这个时候再看一下结果，Bingo!

copy 
    
   

BSell16

ASell15
BSell14
BSell13
BSell12
BSell11
BSell10
BSell9
BSell8
BSell7
BSell6
BSell5
BSell4
BSell3
BSell2
BSell1

4.源码下载

http://download.csdn.net/detail/jackyvincefu/6503759

（编辑：李大同）

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