1 | // **********************************************************************
|
---|
2 | //
|
---|
3 | // Copyright (c) 2000
|
---|
4 | // Object Oriented Concepts, Inc.
|
---|
5 | // Billerica, MA, USA
|
---|
6 | //
|
---|
7 | // All Rights Reserved
|
---|
8 | //
|
---|
9 | // **********************************************************************
|
---|
10 |
|
---|
11 | #ifndef JTC_SYNC_H
|
---|
12 | #define JTC_SYNC_H
|
---|
13 |
|
---|
14 | //
|
---|
15 | // This class is used to lock and unlock a monitor.
|
---|
16 | //
|
---|
17 | class JTCSynchronized
|
---|
18 | {
|
---|
19 | //
|
---|
20 | // Hide copy constructor and assignment operator.
|
---|
21 | //
|
---|
22 | JTCSynchronized(const JTCSynchronized&);
|
---|
23 | void operator=(const JTCSynchronized&);
|
---|
24 |
|
---|
25 | const JTCMonitor* mon_; // Associated monitor.
|
---|
26 | const JTCMutex* mut_; // Associated mutex.
|
---|
27 | const JTCRecursiveMutex* nrmut_; // Associated recursive mutex.
|
---|
28 |
|
---|
29 | enum
|
---|
30 | {
|
---|
31 | LOCKED_MONITOR,
|
---|
32 | LOCKED_MUTEX,
|
---|
33 | LOCKED_RECURSIVE_MUTEX
|
---|
34 | }
|
---|
35 | lockType_; // The lock type
|
---|
36 |
|
---|
37 | public:
|
---|
38 |
|
---|
39 | JTCSynchronized(const JTCMonitor& mon);
|
---|
40 | JTCSynchronized(const JTCMonitor& mon, bool internal);
|
---|
41 | JTCSynchronized(const JTCMutex& m);
|
---|
42 | JTCSynchronized(const JTCRecursiveMutex& m);
|
---|
43 | ~JTCSynchronized();
|
---|
44 | };
|
---|
45 |
|
---|
46 | //
|
---|
47 | // Inlining the methods causes problems with CC 7.1 under SGI
|
---|
48 | //
|
---|
49 | #if !defined(__sgi)
|
---|
50 | inline
|
---|
51 | JTCSynchronized::JTCSynchronized(const JTCMonitor& mon)
|
---|
52 | : mon_(&mon), lockType_(LOCKED_MONITOR)
|
---|
53 | {
|
---|
54 | mon_ -> lock(false);
|
---|
55 | }
|
---|
56 |
|
---|
57 | inline
|
---|
58 | JTCSynchronized::JTCSynchronized(const JTCMonitor& mon, bool internal)
|
---|
59 | : mon_(&mon), lockType_(LOCKED_MONITOR)
|
---|
60 | {
|
---|
61 | mon_ -> lock(internal);
|
---|
62 | }
|
---|
63 |
|
---|
64 | inline
|
---|
65 | JTCSynchronized::JTCSynchronized(const JTCMutex& m)
|
---|
66 | : mut_(&m), lockType_(LOCKED_MUTEX)
|
---|
67 | {
|
---|
68 | mut_ -> lock();
|
---|
69 | }
|
---|
70 |
|
---|
71 | inline
|
---|
72 | JTCSynchronized::JTCSynchronized(const JTCRecursiveMutex& m)
|
---|
73 | : nrmut_(&m), lockType_(LOCKED_RECURSIVE_MUTEX)
|
---|
74 | {
|
---|
75 | nrmut_ -> lock();
|
---|
76 | }
|
---|
77 |
|
---|
78 | inline
|
---|
79 | JTCSynchronized::~JTCSynchronized()
|
---|
80 | {
|
---|
81 | switch(lockType_)
|
---|
82 | {
|
---|
83 | case LOCKED_MONITOR:
|
---|
84 | mon_ -> unlock();
|
---|
85 | break;
|
---|
86 | case LOCKED_MUTEX:
|
---|
87 | mut_ -> unlock();
|
---|
88 | break;
|
---|
89 | case LOCKED_RECURSIVE_MUTEX:
|
---|
90 | nrmut_ -> unlock();
|
---|
91 | break;
|
---|
92 | }
|
---|
93 | }
|
---|
94 | #endif
|
---|
95 |
|
---|
96 | #endif
|
---|