version 1.4.4.1, 2007/03/16 17:29:48
|
version 1.6, 2007/02/09 18:32:20
|
|
|
| |
Uint32 numThreadsCleanedUp = 0; | Uint32 numThreadsCleanedUp = 0; |
| |
Uint32 numIdleThreads = _idleThreads.size(); |
size_t numIdleThreads = _idleThreads.size(); |
for (Uint32 i = 0; i < numIdleThreads; i++) |
for (size_t i = 0; i < numIdleThreads; i++) |
{ | { |
// Do not dip below the minimum thread count | // Do not dip below the minimum thread count |
if (_currentThreads.get() <= (Uint32) _minThreads) | if (_currentThreads.get() <= (Uint32) _minThreads) |
|
|
struct timeval* start, | struct timeval* start, |
struct timeval* interval) | struct timeval* interval) |
{ | { |
|
PEGASUS_ASSERT(interval != 0); |
|
|
// never time out if the interval is zero | // never time out if the interval is zero |
if (interval && (interval->tv_sec == 0) && (interval->tv_usec == 0)) |
if ((interval->tv_sec == 0) && (interval->tv_usec == 0)) |
{ | { |
return false; | return false; |
} | } |
|
|
return 0; | return 0; |
} | } |
_currentThreads++; | _currentThreads++; |
|
Threads::yield(); |
| |
PEG_METHOD_EXIT(); | PEG_METHOD_EXIT(); |
return th; | return th; |