blob: 2aecb429c03142f13d1642ad8d57e0e1b27a2e4f (
plain)
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
|
// $Id$
#ifndef TASK_H
#define TASK_H
#include "ace/Task.h"
#if !defined (ACE_LACKS_PRAGMA_ONCE)
# pragma once
#endif /* ACE_LACKS_PRAGMA_ONCE */
/*
Like the thread-pool server tutorial, we'll derive from ACE_Task<>.
Our goal here is to show off the ACE_Message_Queue and the best way
to do that is to use one to pass data between threads. The easiest
way to create threads is with ACE_Task<>
*/
class Task : public ACE_Task < ACE_MT_SYNCH >
{
public:
typedef ACE_Task < ACE_MT_SYNCH > inherited;
/*
The constructor/destructor are simple but take care of some
necessary housekeeping.
*/
Task (void);
~Task (void);
/*
To make our Task<> derivative look more like other ACE objects
I've added an open() method. It will take care of activate()ing
the object.
*/
int open (int threads = 1);
/*
Our worker method
*/
int svc (void);
/*
All we'll do here is print a message to the user.
*/
int close (u_long flags = 0);
protected:
/*
Just to be clever, I'll use an ACE_Barrier to cause the threads
to sync in svc() before doing any real work.
*/
ACE_Barrier *barrier_;
};
#endif
|
