|
version 1.98, 2005/03/23 03:00:42
|
version 1.99, 2005/04/01 17:26:52
|
|
|
|
| AtomicInt MessageQueueService::_xid(1); | AtomicInt MessageQueueService::_xid(1); |
| Mutex MessageQueueService::_meta_dispatcher_mutex; | Mutex MessageQueueService::_meta_dispatcher_mutex; |
| | |
| static struct timeval create_time = {0, 1}; |
static struct timeval deallocateWait = {300, 0}; |
| static struct timeval destroy_time = {300, 0}; |
|
| | |
| ThreadPool *MessageQueueService::_thread_pool = 0; | ThreadPool *MessageQueueService::_thread_pool = 0; |
| | |
|
|
|
| gettimeofday(&last, NULL); | gettimeofday(&last, NULL); |
| try | try |
| { | { |
| dead_threads = MessageQueueService::_thread_pool->kill_dead_threads(); |
dead_threads = MessageQueueService::_thread_pool->cleanupIdleThreads(); |
| } | } |
| catch(...) | catch(...) |
| { | { |
|
|
|
| { | { |
| throw NullPointer(); | throw NullPointer(); |
| } | } |
| _thread_pool = new ThreadPool(0, "MessageQueueService", 0, 0, |
_thread_pool = |
| create_time, destroy_time); |
new ThreadPool(0, "MessageQueueService", 0, 0, deallocateWait); |
| |
|
| } | } |
| _service_count++; | _service_count++; |
| | |
Return to
MessageQueueService.cpp
CVS log
Up to [Pegasus] / pegasus / src / Pegasus / Common