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
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
|
////////////////////////////////////////////////////////////////////////////////
// The Loki Library
// Copyright (c) 2006 Peter Kmmel
// Permission to use, copy, modify, distribute and sell this software for any
// purpose is hereby granted without fee, provided that the above copyright
// notice appear in all copies and that both that copyright notice and this
// permission notice appear in supporting documentation.
// The author makes no representations about the
// suitability of this software for any purpose. It is provided "as is"
// without express or implied warranty.
////////////////////////////////////////////////////////////////////////////////
// $Header: /cvsroot/loki-lib/loki/test/LockingPtr/main.cpp,v 1.5 2006/04/15 00:41:45 rich_sposato Exp $
#define LOKI_CLASS_LEVEL_THREADING
#ifndef LOKI_CLASS_LEVEL_THREADING
#define LOKI_OBJECT_LEVEL_THREADING
#endif
#include "Thread.h"
#include <loki/LockingPtr.h>
#include <loki/SafeFormat.h>
using namespace Loki;
int g;
int numThreads = 10;
int loop = 5;
struct A
{
A(){};
#define DO for(int i=0; i<10000000; i++) g++;
void print(void* id) const
{
DO;Printf("%p: ----------------\n")(id);
DO;Printf("%p: ---------------\n")(id);
DO;Printf("%p: --------------\n")(id);
DO;Printf("%p: -------------\n")(id);
DO;Printf("%p: ------------\n")(id);
DO;Printf("%p: -----------\n")(id);
DO;Printf("%p: ----------\n")(id);
DO;Printf("%p: ---------\n")(id);
DO;Printf("%p: --------\n")(id);
DO;Printf("%p: -------\n")(id);
DO;Printf("%p: ------\n")(id);
DO;Printf("%p: -----\n")(id);
DO;Printf("%p: ----\n")(id);
DO;Printf("%p: ---\n")(id);
DO;Printf("%p: --\n")(id);
DO;Printf("%p: -\n")(id);
DO;Printf("%p: \n")(id);
DO;Printf("%p: \n")(id);
}
};
typedef Loki::LockingPtr<A,LOKI_DEFAULT_MUTEX,DontPropagateConst> LPtr;
typedef Loki::LockingPtr<A,LOKI_DEFAULT_MUTEX,PropagateConst> CLPtr;
void* RunLocked(void *id)
{
volatile A a;
static Loki::Mutex m;
for(int i=0; i<loop; i++)
{
LPtr l(a,m);
l->print(id);
}
return 0;
}
void* RunConstLocked(void *id)
{
const volatile A a;
static Loki::Mutex m;
for(int i=0; i<loop; i++)
{
CLPtr l(a,m);
l->print(id);
}
return 0;
}
void* Run(void *id)
{
A a;
for(int i=0; i<loop; i++)
a.print(id);
return 0;
}
int main ()
{
std::vector<Thread*> threads;
for(int i=0; i<numThreads; i++)
{
Printf("Creating thread %d\n")(i);
threads.push_back(new Thread(RunLocked,reinterpret_cast<void*>(i)));
}
for(int i=0; i<numThreads; i++)
threads.at(i)->start();
Thread::JoinThreads(threads);
Thread::DeleteThreads(threads);
Printf("--------------------------------------------------------------------------------------\n");
Printf("--------------------------------------------------------------------------------------\n");
Printf("--------------------------------------------------------------------------------------\n");
for(int i=0; i<numThreads; i++)
{
Printf("Creating thread %d\n")(i);
threads.push_back(new Thread(Run,reinterpret_cast<void*>(i)));
}
for(int i=0; i<numThreads; i++)
threads.at(i)->start();
Thread::JoinThreads(threads);
Thread::DeleteThreads(threads);
}
|
