ACE包自带例程的运行问题

peakzhang

最近在学习ACE的线程管理部分，ACE-5.5\ACE_wrappers\examples\APG\ThreadManagement里Signals_vc8.vcproj程序的运行结果怎么会是这样啊？
(1936) Starting thread
(3396) Starting thread
(2664) Starting thread
(2108) Starting thread
(3012) Starting thread
好象信号没有发到。可是程序里明明发啊。

peakzhang

程序如下：

1. // Signals.cpp,v 1.6 2005/12/30 11:02:02 jwillemsen Exp
3. #include "ace/config-lite.h"
4. #if defined (ACE_HAS_THREADS)
6. #include "ace/OS_NS_time.h"
7. #include "ace/OS_NS_unistd.h"
8. #include "ace/Task.h"
9. #include "ace/Log_Msg.h"
10. #include "ace/Signal.h"
12. // Listing 1 code/ch13
13. class SignalableTask : public ACE_Task<ACE_MT_SYNCH>
14. {
15. public:
16.   virtual int handle_signal (int signum,
17.                              siginfo_t *  = 0,
18.                              ucontext_t * = 0)
19.   {
20.     if (signum == SIGUSR1)
21.       {
22.         ACE_DEBUG ((LM_DEBUG,
23.                     ACE_TEXT ("(%t) received a %S signal\n"),
24.                     signum));
25.         handle_alert ();
26.       }
27.     return 0;
28.   }
30.   virtual int svc (void)
31.   {
32.     ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("(%t) Starting thread\n")));
34.     while (1)
35.       {
36.         ACE_Message_Block* mb = 0;
37.         ACE_Time_Value tv (0, 1000);
38.         tv += ACE_OS::time (0);
39.         int result = this->getq (mb, &tv);
40.         if (result == -1 && errno == EWOULDBLOCK)
41.           continue;
42.         else
43.           process_message (mb);
44.       }
46.       ACE_NOTREACHED (return 0);
47.     }
49.   void handle_alert ();
50.   void process_message (ACE_Message_Block *mb);
51. };
52. // Listing 1
54. void
55. SignalableTask::process_message (ACE_Message_Block *)
56. {
57. }
59. void
60. SignalableTask::handle_alert ()
61. {
62. }
64. // Listing 2 code/ch13
65. int ACE_TMAIN (int, ACE_TCHAR *[])
66. {
67.   SignalableTask handler;
68.   handler.activate (THR_NEW_LWP | THR_JOINABLE , 5);
70.   ACE_Sig_Handler sh;
71.   sh.register_handler (SIGUSR1, &handler);
73.   ACE_OS::sleep (1);
75.   ACE_Thread_Manager::instance () ->
76.     kill_grp (handler.grp_id (), SIGUSR1);
77.   handler.wait ();
78.   return 0;
79. }
80. // Listing 2
81. #if defined (ACE_HAS_EXPLICIT_TEMPLATE_INSTANTIATION)
82. template class ACE_Task<ACE_MT_SYNCH>;
83. #elif defined (ACE_HAS_TEMPLATE_INSTANTIATION_PRAGMA)
84. pragma instantiate ACE_Task<ACE_MT_SYNCH>;
85. #endif /* ACE_HAS_EXPLICIT_TEMPLATE_INSTANTIATION */
87. #else
88. #include "ace/OS_main.h"
89. #include "ace/OS_NS_stdio.h"
91. int ACE_TMAIN (int, ACE_TCHAR *[])
92. {
93.   ACE_OS::puts (ACE_TEXT ("This example requires threads."));
94.   return 0;
95. }
97. #endif /* ACE_HAS_THREADS */

复制代码

[ 本帖最后由 peakzhang 于 2007-12-11 22:18 编辑 ]

peakzhang

信号好像是Unix下比较常用,windows下 ACE_Thread_Manager::instance () ->kill_grp (handler.grp_id (), SIGUSR1);这个没有被实现,所以返回值是-1.

楼主还是试试用消息吧,ACE_Message_Block.