C++11多线程std::thread的简单使用

转自天涯海阁的博客

1. bool HelloWorld::init()   
2. {   
3.     if ( !Layer::init() )   
4.     {   
5.         return false;   
6.     }   
7.        
8.     std::thread t1(&HelloWorld::myThread,this);//创建一个分支线程，回调到myThread函数里   
9.     t1.join();   
10. //  t1.detach();   
11.    
12.    
13.     CCLOG("in major thread");//在主线程   
14.    
15.    
16.     return true;   
17. }   
18.    
19. void HelloWorld::myThread()   
20. {   
21.     CCLOG("in my thread");   
22. }   

1. std::thread t1(&HelloWorld::myThread,this);//创建一个分支线程，回调到myThread函数里   
2. t1.detach();   

1. bool HelloWorld::init()   
2. {   
3.     if ( !Layer::init() )   
4.     {   
5.         return false;   
6.     }   
7.        
8.     std::thread t1(&HelloWorld::myThread,this,10,20);//创建一个分支线程，回调到myThread函数里   
9.     t1.join();   
10. //  t1.detach();   
11.    
12.    
13.     CCLOG("in major thread");//在主线程   
14.     return true;   
15. }   
16.    
17.    
18. void HelloWorld::myThread(int first,int second)   
19. {   
20.     CCLOG("in my thread,first = %d,second = %d",first,second);   
21. }   

1. //HelloWorld.h   
2. class HelloWorld : public cocos2d::Layer   
3. {   
4. public:   
5.     static cocos2d::Scene* createScene();   
6.     virtual bool init();     
7.        
8.     CREATE_FUNC(HelloWorld);   
9.    
10.     void myThreadA();//线程A   
11.     void myThreadB();//线程B   
12.    
13.     int tickets;//票数     
14.    
15. };   
16.    
17. //.cpp   
18. bool HelloWorld::init()   
19. {   
20.     if ( !Layer::init() )   
21.     {   
22.         return false;   
23.     }   
24.        
25.     tickets = 100;//100张票   
26.    
27.     std::thread tA(&HelloWorld::myThreadA,this);//创建一个分支线程，回调到myThread函数里   
28.     std::thread tB(&HelloWorld::myThreadB,this);   
29.     tA.detach();   
30.     tB.detach();   
31. //  t1.detach();   
32.    
33.     CCLOG("in major thread");//在主线程   
34.     return true;   
35. }   
36.    
37. void HelloWorld::myThreadA()   
38. {   
39.     while(true)     
40.     {     
41.         if(tickets>0)     
42.         {     
43.             Sleep(10);   
44.             CCLOG("A Sell %d",tickets--);//输出售票，每次减1     
45.         }     
46.         else {     
47.             break;     
48.         }     
49.     }     
50. }   
51. void HelloWorld::myThreadB()   
52. {   
53.     while(true)     
54.     {     
55.         if (tickets>0)     
56.         {     
57.             Sleep(10);   
58.             CCLOG("B Sell %d",tickets--);     
59.         }     
60.         else      
61.         {     
62.             break;     
63.         }     
64.     }     
65. }   

1. Sleep(100);   

1. std::mutex mutex;//线程互斥对象   

1. void HelloWorld::myThreadA()   
2. {   
3.     while(true)     
4.     {     
5.         mutex.lock();//加锁   
6.         if(tickets>0)     
7.         {     
8.             Sleep(10);   
9.             CCLOG("A Sell %d",tickets--);//输出售票，每次减1     
10.             mutex.unlock();//解锁   
11.         }     
12.         else {     
13.             mutex.unlock();   
14.             break;     
15.                
16.         }     
17.     }     
18. }   
19. void HelloWorld::myThreadB()   
20. {   
21.     while(true)     
22.     {     
23.         mutex.lock();   
24.         if (tickets>0)     
25.         {     
26.             Sleep(10);   
27.             CCLOG("B Sell %d",tickets--);     
28.             mutex.unlock();   
29.         }     
30.         else      
31.         {     
32.             mutex.unlock();   
33.             break;                 
34.         }     
35.     }     
36. }