问个ACE_Thread_Manage的简单问题

phil2360

是这样，在学习ACE，刚看到多线程那块，看着例子试着写些东西做练习，现在碰到这样一个问题，我的代码在调用ACE_Thread_Manage::instance()->spawn_n的时候总会出错，调试的时候在代码ACE_OS::thread_mutex_lock()这个函数里发现m这个参数是空指针，看来看去跟例子里的调用方法好像没区别丫。代码贴出来，大家帮忙看看
另外请教一下，spawn这个函数里头那些个THR_NEW_LWP还有THR_DETACHED这些标志位什么意思？

2. #include <ace/Thread_Manager.h>
3. #include <ace/Synch.h>
4. #include <ace/Log_Msg.h>
5. struct THREADARG
6. {
7. public:
8. THREADARG(ACE_Mutex * mutex_p)
9.   : mutex_(mutex_p)
10.   , number(0)
11. {
12. }
13. ACE_Mutex * mutex_;
14. int   number;
15. };
16. static void * WorkThread(void * arg)
17. {
18. THREADARG * arg_ = (THREADARG *)arg;
19. ACE_DEBUG((LM_DEBUG,"Begin thread id = %t,number = %d\n",arg_->number));
20. //arg_->mutex_->acquire();
21. arg_->number++;
22. ACE_OS::sleep(1);
23. ACE_DEBUG((LM_DEBUG,"Thread id = %t,number = %d\n",arg_->number));
24. //arg_->mutex_->release();
25. //arg_->mutex_->acquire();
26. arg_->number++;
27. ACE_OS::sleep(1);
28. ACE_DEBUG((LM_DEBUG,"Thread id = %t,number = %d\n",arg_->number));
29. //arg_->mutex_->release();
30. ACE_DEBUG((LM_DEBUG,"Thread id = %t exit!\n"));
31. return 0;
32. }
33. int _tmain(int argc, _TCHAR* argv[])
34. {
35. ACE_DEBUG((LM_DEBUG,"Now begin work 5 thread!\n"));
36. ACE_Mutex mutex;
37. THREADARG thr_arg(&mutex);
38. //  for (int i = 0;i < 5;i++)
39. //   ACE_Thread_Manager::instance()->spawn((ACE_THR_FUNC)WorkThread,&thr_arg,THR_NEW_LWP | THR_DETACHED,0,0,ACE_DEFAULT_THREAD_PRIORITY,1);
40. ACE_Thread_Manager * thread_manage = ACE_Thread_Manager::instance();
41. int nret = thread_manage->spawn_n(5,(ACE_THR_FUNC)WorkThread,(void *)&thr_arg,THR_NEW_LWP ,ACE_DEFAULT_THREAD_PRIORITY);
42. if (nret == -1)
43.   ACE_DEBUG((LM_DEBUG,"Thread begin failed!\n"));
44. ACE_Thread_Manager::instance()->wait_grp(nret);
45. ACE_DEBUG((LM_DEBUG,"All thread exit!\n"));
46. return 0;
47. }

复制代码

_coco

1. #include <ace/Thread_Manager.h>
2. #include <ace/Synch.h>
3. #include <ace/Log_Msg.h>
5. #if defined(WIN32)
6. #pragma comment(lib,"ACEd.lib")
7. #endif
9. struct THREADARG
10. {
11. public:
12.     THREADARG(ACE_Mutex * mutex_p)
13.         : mutex_(mutex_p)
14.         , number(0)
15.     {
16.     }
17.     ACE_Mutex * mutex_;
18.     int   number;
19. };
20. static void * WorkThread(void * arg)
21. {
22.     THREADARG * arg_ = (THREADARG *)arg;
23.    
24.     ACE_DEBUG((LM_DEBUG,"%t number = %d\n",arg_->number));
25.    
26.     arg_->mutex_->acquire();
27.     arg_->number++;
28.     arg_->mutex_->release();
30.     ACE_OS::sleep(1);
32.     ACE_DEBUG((LM_DEBUG,"%t number = %d\n",arg_->number));
33.    
34.     arg_->mutex_->acquire();
35.     arg_->number++;
36.     arg_->mutex_->release();
38.     ACE_OS::sleep(1);
40.     ACE_DEBUG((LM_DEBUG,"%t number = %d\n",arg_->number));
41.    
42.     ACE_DEBUG((LM_DEBUG,"%t exit!\n"));
44.     return 0;
45. }
46. int ACE_TMAIN(int argc, ACE_TCHAR* argv[])
47. {
48.     ACE_DEBUG((LM_DEBUG,"Now begin work 5 thread!\n"));
50.     ACE_Mutex mutex;
51.     THREADARG thr_arg(&mutex);
53.     ACE_Thread_Manager * thread_manage = ACE_Thread_Manager::instance();
54.     int nret = thread_manage->spawn_n(
55.         5,
56.         (ACE_THR_FUNC)WorkThread,
57.         (void *)&thr_arg,
58.         THR_NEW_LWP | THR_JOINABLE );
60.     if (nret == -1)
61.         ACE_ERROR_RETURN((LM_DEBUG,"Thread begin failed!\n"), -1);
63.     ACE_Thread_Manager::instance()->wait_grp(nret);
65.     ACE_DEBUG((LM_DEBUG,"All thread exit!\n"));
66.    
67.     return 0;
68. }

复制代码

出现错误的原因估计是main函数已经退出，但是线程还没有退出。

分离的（THR_DETACHED），ACE会在线程退出时自动清理这个线程持有的所有资源，其它线程无法查看这个线程的退出状态。
可会合的（THR_JOINABLE），主线程通过调用任务对象的wait()来等待子线程，如果你没有wait()它的话，你就可能泄漏系统资源。

关于你说的其它的标志位，你可以上google搜索一下，这方面的资源还是挺多的。

http://blog.csdn.net/xjtuse_mal/archive/2009/01/07/3726676.aspx

[ 本帖最后由 _coco 于 2009-2-20 21:12 编辑 ]

blaight

你得使用ACE_TMAIN作为入口，完成对ACE的初始化。