Changeset 4721 for source/ariba/utility/system
- Timestamp:
- Jul 3, 2009, 11:53:21 AM (15 years ago)
- File:
-
- 1 edited
Legend:
- Unmodified
- Added
- Removed
-
source/ariba/utility/system/SystemQueue.cpp
r4712 r4721 133 133 void SystemQueue::QueueThread::run(){ 134 134 running = true; 135 135 136 queueThread = new boost::thread( 136 137 boost::bind(&QueueThread::threadFunc, this) ); … … 139 140 void SystemQueue::QueueThread::cancel(){ 140 141 142 logging_debug("cancelling system queue"); 143 141 144 // cause the thread to exit 142 145 { 143 // get the lock, when we got the lock the 146 // get the lock, when we got the lock the 144 147 // queue thread must be in itemsAvailable.wait() 145 148 boost::mutex::scoped_lock lock(queueMutex); 146 149 147 150 // set the running indicator and signal to run on 148 151 // this will run the thread and quit it … … 152 155 153 156 // wait until the thread has exited 157 logging_debug("joining system queue thread"); 154 158 queueThread->join(); 155 159 156 160 // delete pending events 161 logging_debug("deleting pending system queue events"); 157 162 while( eventsQueue.size() > 0 ){ 158 163 eventsQueue.erase( eventsQueue.begin() );
Note:
See TracChangeset
for help on using the changeset viewer.