blob: 877ac98ede5cd4259aa026f94492063e03495ffc (
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
|
// $Id$
#ifndef TASK_H
#define TASK_H
#include "ace/Task.h"
#if !defined (ACE_LACKS_PRAGMA_ONCE)
# pragma once
#endif /* ACE_LACKS_PRAGMA_ONCE */
/*
This is our basic thread-pool Task. We have a choice of pool size
on the open() and the usual svc() and close() methods.
A new addition is the ACE_Barrier object. This will allow the
synchronization of our svc() methods so that they all start at the
"same" time. The normal case may allow one thread to start working
earlier than others. There's no real harm in it but you can get
better "work by thread" statistics if they start out together.
*/
class Task : public ACE_Task < ACE_MT_SYNCH >
{
public:
typedef ACE_Task < ACE_MT_SYNCH > inherited;
Task (void);
~Task (void);
int open (int threads = 1);
int svc (void);
int close (u_long flags = 0);
protected:
ACE_Barrier * barrier_;
};
#endif
|
