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
|
/*
* main.h
*
* PWLib application header file for ThreadSafe
*
* Copyright 2002 Equivalence
*
* $Log: main.h,v $
* Revision 1.6 2003/10/27 22:12:56 dereksmithies
* Add more good changes to get Compare method work. Thanks to Gene Small
*
* Revision 1.5 2003/10/13 23:38:31 dereksmithies
* Add debugging statements, usage(), Fixed Compare method. Thanks Gene Small.
*
* Revision 1.4 2002/12/11 03:38:35 robertj
* Added more tests
*
* Revision 1.3 2002/12/02 01:08:29 robertj
* Updated to latest safe collection classes, thanks Vladimir Nesic
*
* Revision 1.2 2002/05/02 00:30:03 robertj
* Allowed for non-template containers
*
* Revision 1.1 2002/05/01 04:16:44 robertj
* Added thread safe collection classes.
*
*/
#ifndef _ThreadSafe_MAIN_H
#define _ThreadSafe_MAIN_H
#include <ptlib/safecoll.h>
class ThreadSafe;
class TestObject : public PSafeObject
{
PCLASSINFO(TestObject, PSafeObject);
public:
TestObject(ThreadSafe & process, unsigned val);
~TestObject();
Comparison Compare(const PObject & obj) const;
void PrintOn(ostream & strm) const;
ThreadSafe & process;
unsigned value;
};
class ThreadSafe : public PProcess
{
PCLASSINFO(ThreadSafe, PProcess)
public:
ThreadSafe();
~ThreadSafe();
void Main();
private:
void Usage();
void Test1(PArgList & args);
void Test1Output();
void Test1OutputEnd();
PDECLARE_NOTIFIER(PThread, ThreadSafe, Test1Thread);
void Test2(PArgList & args);
PDECLARE_NOTIFIER(PThread, ThreadSafe, Test2Thread1);
PDECLARE_NOTIFIER(PThread, ThreadSafe, Test2Thread2);
void Test3(PArgList & args);
PDECLARE_NOTIFIER(PThread, ThreadSafe, Test3Thread1);
PDECLARE_NOTIFIER(PThread, ThreadSafe, Test3Thread2);
PSafeList<TestObject> unsorted;
PSafeSortedList<TestObject> sorted;
PSafeDictionary<POrdinalKey, TestObject> sparse;
PINDEX threadCount;
PTimeInterval startTick;
PMutex mutexObjects;
unsigned totalObjects;
unsigned currentObjects;
friend class TestObject;
};
#endif // _ThreadSafe_MAIN_H
// End of File ///////////////////////////////////////////////////////////////
|
