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
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
|
/*
* This file is part of the Code::Blocks IDE and licensed under the GNU Lesser General Public License, version 3
* http://www.gnu.org/licenses/lgpl-3.0.html
*
* $Revision: 4909 $
* $Id: managedthread.cpp 4909 2008-02-27 13:15:26Z mortenmacfly $
* $HeadURL: svn+ssh://jenslody@svn.berlios.de/svnroot/repos/codeblocks/trunk/src/sdk/managedthread.cpp $
*/
#include "sdk_precomp.h"
#include "managedthread.h"
#include <wx/utils.h>
/// Keeps count of running threads
wxCriticalSection ManagedThread::s_count_running_mutex;
wxCriticalSection ManagedThread::s_list_mutex;
unsigned long ManagedThread::s_running = 0;
bool ManagedThread::s_abort_all = false;
static ManagedThreadsArray s_threadslist;
ManagedThread::ManagedThread(bool* abortflag) :
wxThread(wxTHREAD_JOINABLE),
m_pAbort(abortflag)
{
wxCriticalSectionLocker lock(s_list_mutex);
s_threadslist.Add(this);
}
ManagedThread::~ManagedThread()
{
// wxCriticalSectionLocker* lock;
// lock = new wxCriticalSectionLocker(s_list_mutex);
// NOTE: DeleteThreadFromList() locks the mutex by itself
DeleteThreadFromList(this); // Deletes thread from list
// delete lock;
}
unsigned long ManagedThread::count_running()
{
wxCriticalSectionLocker lock(ManagedThread::s_count_running_mutex);
return ManagedThread::s_running;
}
unsigned long ManagedThread::count_threads()
{
wxCriticalSectionLocker lock(ManagedThread::s_list_mutex);
return s_threadslist.GetCount();
}
ManagedThread* ManagedThread::GetThread(size_t n)
{
wxCriticalSectionLocker lock(ManagedThread::s_list_mutex);
if(n>=s_threadslist.GetCount())
return 0L;
return s_threadslist.Item(n);
}
void ManagedThread::abort_all()
{
// 1) Send signal to threads telling to terminate ASAP
if(count_running() > 0)
{
ManagedThread::s_abort_all = true;
while(count_running() > 0)
{
wxMilliSleep(5);
}
wxMilliSleep(50);
// (there's a tiny delay between the thread disminishing the count
// and the thread actually stopping)
// 50 ms should be more than enough
}
// 2) Delete thread objects
ManagedThread *thread;
for(unsigned int i = 0; i < count_threads();++i)
{
thread = GetThread(i);
if(thread)
{
if(thread->IsAlive())
{ thread->Delete(); }
delete thread;
}
}
// 3) Clear thread list
wxCriticalSectionLocker lock(ManagedThread::s_list_mutex);
s_threadslist.Clear();
// 4) Reset the abort flag now that no threads are running
ManagedThread::s_abort_all = false;
}
void ManagedThread::abort(bool* flag,bool delete_thread)
{
if(!flag)
return;
// 1) Send signal to threads telling to terminate ASAP
if(count_running() > 0)
{
*flag = true;
wxMilliSleep(50);
}
// 2) Delete thread objects
ManagedThread *thread;
for(unsigned int i = 0; i < count_threads();++i)
{
thread = GetThread(i);
if(!thread)
continue;
if(thread->get_abort_location()!=flag)
continue;
if(thread->IsAlive())
{ thread->Delete(); }
if(delete_thread)
delete thread;
}
// 4) Reset the abort flag now that no associated threads are running
*flag = false;
}
void* ManagedThread::Entry()
{
void* result;
{
wxCriticalSectionLocker lock(s_count_running_mutex);
s_running++;
}
result = DoRun();
{
wxCriticalSectionLocker lock(s_count_running_mutex);
if(s_running > 0)
s_running--;
}
return result;
}
void* ManagedThread::DoRun()
{ return 0; }
void ManagedThread::DeleteThreadFromList(ManagedThread* thread)
{
wxCriticalSectionLocker lock(ManagedThread::s_list_mutex);
unsigned int i = 0;
while(i < s_threadslist.GetCount())
{
if(s_threadslist[i]==thread)
{
s_threadslist.RemoveAt(i,1);
}
else
++i;
}
}
bool ManagedThread::TestDestroy()
{
return is_aborted() || wxThread::TestDestroy();
}
bool ManagedThread::is_aborted()
{
if(ManagedThread::s_abort_all)
return true;
if(m_pAbort)
return (*m_pAbort);
return false;
}
|