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
|
/* -*- Mode: C++; tab-width: 4; indent-tabs-mode: nil; c-basic-offset: 4 -*-
*/
/** BEGIN COPYRIGHT BLOCK
* This library is free software; you can redistribute it and/or
* modify it under the terms of the GNU Lesser General Public
* License as published by the Free Software Foundation;
* version 2.1 of the License.
*
* This library is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
* Lesser General Public License for more details.
*
* You should have received a copy of the GNU Lesser General Public
* License along with this library; if not, write to the Free Software
* Foundation, Inc., 51 Franklin Street, Fifth Floor,
* Boston, MA 02110-1301 USA
*
* Copyright (C) 2007 Red Hat, Inc.
* All rights reserved.
* END COPYRIGHT BLOCK **/
#ifndef __THREAD_POOL_H
#define __THREAD_POOL_H
#ifdef HAVE_CONFIG_H
#ifndef AUTOTOOLS_CONFIG_H
#define AUTOTOOLS_CONFIG_H
/* Eliminate warnings when using Autotools */
#undef PACKAGE_BUGREPORT
#undef PACKAGE_NAME
#undef PACKAGE_STRING
#undef PACKAGE_TARNAME
#undef PACKAGE_VERSION
#include <config.h>
#endif /* AUTOTOOLS_CONFIG_H */
#endif /* HAVE_CONFIG_H */
/**
* ThreadPool.h 1.000 06/12/2002
*
* A worker thread pool.
*
* @author Surendra Rajam
* @version 1.000, 06/12/2002
*/
class EXPORT_DECL ThreadPool {
friend class WorkerThread;
public:
/**
* Constructor - creates the pool with default values
*
* @param name name of the threadpool
*/
ThreadPool(const char* name);
/**
* Constructor
*
* @param name name of the threadpool
* @param min minimum threads in the pool
* @param max maximum threads that can be created
* @param timeout timeout for each thread
*/
ThreadPool(const char* name, int min, int max, int timeout);
/**
* Destructor
*/
virtual ~ThreadPool();
public:
/**
* Initializes the thread pool with minimum threads
*/
void Init();
/**
* Shutdown the thread pool
*/
void Shutdown();
/**
* Adds a task for future execution
*
* @param task a task to execute
*/
void AddTask(ScheduledTask* task);
/**
* Executes the task immediately
*
* @param task a task to execute
*/
void ExecuteTask(ScheduledTask* task);
/**
* Gets the number of active threads in the pool
*
* @return number of active threads
*/
int GetThreads();
/**
* Gets the number of pending tasks in the list
*
* @return number of pending tasks
*/
int GetPendingTasks();
/**
* Function to start a NSPR thread
*/
static void StartWorkerThread(void* arg);
private:
/**
* Initializes constructor params
*/
void ConstructorInit(const char* name, int min, int max, int timeout);
/**
* Creates a new thread
*/
void CreateNewThread();
/**
* Notify one of the threads waiting on a condition
*/
void Notify();
private:
char* m_name;
TaskList* m_taskList;
int m_minThreads;
int m_maxThreads;
int m_timeout;
int m_threads;
int m_activeThreads;
PRBool m_threadWait;
PRLock* m_threadLock;
PRCondVar* m_threadCondVar;
PRBool m_newThreadInitialized;
PRLock* m_newThreadLock;
PRCondVar* m_newThreadCondVar;
bool m_keepRunning;
};
#endif // __THREAD_POOL_H
|
