|
version 1.20, 2002/06/07 20:52:13
|
version 1.21, 2002/06/19 22:06:33
|
|
|
|
| memset(_key, 0x00, 17); | memset(_key, 0x00, 17); |
| if(key != 0) | if(key != 0) |
| strncpy(_key, key, 16); | strncpy(_key, key, 16); |
| if(_max_threads < initial_size) |
if(_max_threads > 0 && _max_threads < initial_size) |
| _max_threads = initial_size; | _max_threads = initial_size; |
| if(_min_threads > initial_size) | if(_min_threads > initial_size) |
| _min_threads = initial_size; | _min_threads = initial_size; |
|
|
|
| { | { |
| _check_deadlock(&start) ; | _check_deadlock(&start) ; |
| | |
| if(_current_threads < _max_threads) |
if(_max_threads == 0 || _current_threads < _max_threads) |
| { | { |
| th = _init_thread(); | th = _init_thread(); |
| continue; | continue; |
|
|
|
| int i = 0; | int i = 0; |
| AtomicInt needed(0); | AtomicInt needed(0); |
| | |
| for( q = map[i] ; i < 2; i++, q = map[i], pegasus_sleep(1)) |
for( ; i < 1; i++) |
| { | { |
| |
q = map[i]; |
| if(q->count() > 0 ) | if(q->count() > 0 ) |
| { | { |
| try | try |
Return to
Thread.cpp
CVS log
Up to [Pegasus] / pegasus / src / Pegasus / Common