1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
|
// $Id: Priorities.cpp 80826 2008-03-04 14:51:23Z wotte $
#include "ace/config-lite.h"
#if defined (ACE_HAS_THREADS)
#include "ace/Task.h"
#include "ace/Log_Msg.h"
#include "ace/OS_NS_unistd.h"
// Listing 2 code/ch13
class HA_CommandHandler : public ACE_Task<ACE_MT_SYNCH>
{
public:
HA_CommandHandler (const char *name) : name_ (name)
{ }
virtual int svc (void)
{
ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("(%t) starting up %C\n"),
name_));
ACE_OS::sleep (2);
ACE_Message_Block *mb = 0;
while (this->getq (mb) != -1)
{
if (mb->msg_type () == ACE_Message_Block::MB_BREAK)
{
mb->release ();
break;
}
process_message (mb);
mb->release ();
}
return 0;
}
void process_message (ACE_Message_Block *)
{
ACE_DEBUG ((LM_DEBUG,
ACE_TEXT ("(%t) Processing message %C\n"),
name_));
// Simulate compute bound task.
for (int i = 0; i < 100; i++)
;
}
private:
const char *name_;
};
// Listing 2
#if !defined (ACE_THR_PRI_OTHER_MAX)
// This should be fixed in ACE... There's no _MAX, _MIN values for
// thread priorities.
#if defined (ACE_WIN32)
# define ACE_THR_PRI_OTHER_MAX ((ACE_THR_PRI_OTHER_DEF) + 1)
#elif defined (VXWORKS)
# define ACE_THR_PRI_OTHER_MAX 0
#endif
#endif
// Listing 1 code/ch13
int ACE_TMAIN (int, ACE_TCHAR *[])
{
HA_CommandHandler hp_handler ("HighPriority");
hp_handler.activate (THR_NEW_LWP | THR_JOINABLE,
1, 1, ACE_THR_PRI_OTHER_MAX);
HA_CommandHandler lp_handler ("LowPriority");
lp_handler.activate (THR_NEW_LWP | THR_JOINABLE,
1, 1, ACE_THR_PRI_OTHER_DEF);
ACE_Message_Block mb;
for (int i = 0; i < 100; i++)
{
ACE_Message_Block *mb_hp, *mb_lp;
mb_hp = mb.clone ();
mb_lp = mb.clone ();
hp_handler.putq (mb_hp);
lp_handler.putq (mb_lp);
}
ACE_Message_Block stop (0, ACE_Message_Block::MB_BREAK);
hp_handler.putq (stop.clone ());
lp_handler.putq (stop.clone ());
hp_handler.wait ();
lp_handler.wait ();
return 0;
}
// Listing 1
#else
#include "ace/OS_main.h"
#include "ace/OS_NS_stdio.h"
int ACE_TMAIN (int, ACE_TCHAR *[])
{
ACE_OS::puts (ACE_TEXT ("This example requires threads."));
return 0;
}
#endif /* ACE_HAS_THREADS */
|
