comparison Orthanc/Core/MultiThreading/SharedMessageQueue.cpp @ 145:d850500b8ca6

sync
author Sebastien Jodogne <s.jodogne@gmail.com>
date Tue, 08 Nov 2016 10:15:05 +0100
parents 3809121c3290
children 5dc54316d68b
comparison
equal deleted inserted replaced
144:daf99382bc18 145:d850500b8ca6
183 void SharedMessageQueue::SetLifoPolicy() 183 void SharedMessageQueue::SetLifoPolicy()
184 { 184 {
185 boost::mutex::scoped_lock lock(mutex_); 185 boost::mutex::scoped_lock lock(mutex_);
186 isFifo_ = false; 186 isFifo_ = false;
187 } 187 }
188
189 void SharedMessageQueue::Clear()
190 {
191 boost::mutex::scoped_lock lock(mutex_);
192
193 if (queue_.empty())
194 {
195 return;
196 }
197 else
198 {
199 while (!queue_.empty())
200 {
201 std::auto_ptr<IDynamicObject> message(queue_.front());
202 queue_.pop_front();
203 }
204
205 emptied_.notify_all();
206 }
207 }
188 } 208 }