求c++多线程例子

guaixiaolu

哪位老大提供一个c++的多线程测试例子，简单的完整的，能够直接编译通过的，我使用的环境是AIX5.0，小弟刚学C++，边学边测试，谢谢了

guaixiaolu

自己顶一个

yangsf5

http://search.chinaunix.net/bbs. ... ;stype=&first=0

http://bbs.chinaunix.net/viewthr ... %B3%CC+%C0%FD%D7%D3

http://bbs.chinaunix.net/viewthr ... FD%D7%D3&page=1

stratovarius

这两天刚刚写了一个. 功能还好, 基本上可以用啦.

1. 
   
2. /*
   
3. * thread.h
   
4. *
   
5. *  Created on: 2008-11-25
   
6. *      Author: Administrator
   
7. */
   
8. 
   
9. #ifndef THREAD_H_
   
10. #define THREAD_H_
    
11. 
    
12. #include <pthread.h>
    
13. #include <vector>
    
14. #include <map>
    
15. 
    
16. namespace x
    
17. {
    
18. using namespace std;
    
19. /**
    
20. * 这是一个线程虚基类，编写任何线程时，只要继承thread，并实现其中的纯虚函数run()，
    
21. * 然后用start启动即可
    
22. */
    
23. class Thread
    
24. {
    
25. public:
    
26.     Thread();
    
27.     virtual ~Thread();
    
28. public:
    
29.     enum { THR_JOINABLE = 0, THR_DETACHED  };
    
30. 
    
31. //    enum {  THR_STATE_READY = 0, // 就绪状态，在调用线程函数run()之前
    
32. //            THR_STATE_RUNNING, // 工作状态，启动run()函数，但未返回
    
33. //            THR_STATE_RETURN, // 线程成功返回
    
34. //            THR_STATE_ERROR // 线程失败返回
    
35. //         };
    
36. 
    
37. protected:
    
38.     static void* thr_run(void* args);
    
39. 
    
40. protected:
    
41.     /**
    
42.      * 线程方法，继承thread，实现这个run方法即可
    
43.      */
    
44.     virtual int run() = 0;
    
45. 
    
46. public:
    
47.     /**
    
48.      * 线程启动方法
    
49.      */
    
50.     int start(int thr_num = 1, int state = Thread::THR_JOINABLE );
    
51. 
    
52.     /**
    
53.      * 等待所有线程结束
    
54.      */
    
55.     int wait();
    
56. 
    
57.     /**
    
58.      * 线程是否可连接
    
59.      * @return
    
60.      *         1: YES
    
61.      *         0: NO
    
62.      */
    
63.     int joinable();
    
64. 
    
65.     /**
    
66.      * 本线程对象共有多少个线程在运行
    
67.      */
    
68.     int thread_count();
    
69. 
    
70. private:
    
71.     // 线程ID集合
    
72.     vector<pthread_t> thrIdList_;
    
73. 
    
74.     // 线程属性
    
75.     pthread_attr_t thrAttr_;
    
76. 
    
77.     // 线程是否可连接
    
78.     int joinable_;
    
79. 
    
80.     int isThrAttrInit_;
    
81. 
    
82. }; // class thread
    
83. } // namespace x
    
84. 
    
85. #endif /* THREAD_H_ */
    

复制代码

1. 
   
2. /*
   
3. * thread.cpp
   
4. *
   
5. *  Created on: 2008-11-25
   
6. *      Author: Administrator
   
7. */
   
8. 
   
9. #include "Thread.h"
   
10. 
    
11. namespace x
    
12. {
    
13. 
    
14.     Thread::Thread():joinable_(PTHREAD_CREATE_JOINABLE), isThrAttrInit_(0)
    
15.     {
    
16.     }
    
17. 
    
18.     Thread::~Thread()
    
19.     {
    
20.         if( this->isThrAttrInit_ == 1 ) // 如果线程属性对象被成功的设置，则对其释放内存
    
21.         {
    
22.             if( pthread_attr_destroy(& this->thrAttr_) == 0 )
    
23.             {
    
24.                 ; // todo
    
25.             }
    
26.             else
    
27.             {
    
28.                 ; // todo
    
29.             }
    
30.         }
    
31.     }
    
32. 
    
33.     void* Thread::thr_run(void* args)
    
34.     {
    
35.         int thr_ret = 0;
    
36.         Thread *thr_objp = (Thread*) args;
    
37. 
    
38.         thr_ret = thr_objp->run();
    
39. 
    
40.         if( thr_ret == 0 ) { // 线程正常退出
    
41.             ; // todo
    
42.         } else { // 返回值为非0，异常退出
    
43.             ; // todo
    
44.         }
    
45.         return (void*)thr_ret;
    
46.     }
    
47. 
    
48.     int Thread::start(int thr_num, int state)
    
49.     {
    
50.         int err = 0;
    
51. 
    
52.         err = pthread_attr_init(& this->thrAttr_);
    
53.         if( err != 0 )        return err;
    
54. 
    
55.         if( state == Thread::THR_DETACHED )
    
56.         {
    
57.             err = pthread_attr_setdetachstate(& this->thrAttr_, PTHREAD_CREATE_DETACHED);
    
58.             if( err != 0 )        return err;
    
59.             this->joinable_ = PTHREAD_CREATE_DETACHED;
    
60.         }
    
61.         else
    
62.         {
    
63.             err = pthread_attr_setdetachstate(& this->thrAttr_, PTHREAD_CREATE_JOINABLE);
    
64.             if( err != 0 )        return err;
    
65.             this->joinable_ = PTHREAD_CREATE_JOINABLE;
    
66.         }
    
67. 
    
68.         // 线程属性已经被成功设置
    
69.         this->isThrAttrInit_ = 1;
    
70. 
    
71.         thr_num = (thr_num > 0) ? thr_num : 1;
    
72. 
    
73.         pthread_t tid;
    
74.         for(int i = 0; i < thr_num; i++ )
    
75.         {
    
76.             err = pthread_create(& tid, & this->thrAttr_, thr_run, this);
    
77.             // save the thread id
    
78.             if( err == 0 )
    
79.                 this->thrIdList_.push_back(tid);
    
80.         }
    
81.         return err;
    
82.     }
    
83. 
    
84.     int Thread::wait()
    
85.     {
    
86.         if( this->joinable())
    
87.         {// 如果是可连接的，则等待
    
88.             int threadCount = thread_count();
    
89.             for(int i = 0; i < threadCount; i++ )
    
90.             {
    
91.                 pthread_join( this->thrIdList_.at(i), NULL);
    
92.             }
    
93.         }
    
94.         return 0;
    
95.     }
    
96. 
    
97. 
    
98.     int Thread::joinable()
    
99.     {
    
100.         return this->joinable_ == PTHREAD_CREATE_JOINABLE;
     
101.     }
     
102. 
     
103.     int Thread::thread_count()
     
104.     {
     
105.         return this->thrIdList_.size();
     
106.     }
     
107. }
     
108. 
     

复制代码

alexhappy

原帖由 stratovarius 于 2008-11-26 17:30 发表
这两天刚刚写了一个. 功能还好, 基本上可以用啦.


/*
* thread.h
*
*  Created on: 2008-11-25
*      Author: Administrator
*/

#ifndef THREAD_H_
#define THREAD_H_

#include
#inclu ...

功能太弱。。。。基本上等于什么也没做。。。。