Commit 3aa0fda3e06bd0bf1d9d16a3919c08c7189c9106
1 parent
4d446aef
代码优化
Showing
1 changed file
with
3 additions
and
2 deletions
src/decoder/interface/DecoderManager.cpp
@@ -224,8 +224,7 @@ void DecoderManager::closeAllDecoder() | @@ -224,8 +224,7 @@ void DecoderManager::closeAllDecoder() | ||
224 | 224 | ||
225 | void DecoderManager::closeAllFinishedDecoder() | 225 | void DecoderManager::closeAllFinishedDecoder() |
226 | { | 226 | { |
227 | - std::lock_guard<std::mutex> l(m_mutex); | ||
228 | - | 227 | + m_mutex.lock(); |
229 | for(auto iter = decoderMap.begin(); iter != decoderMap.end(); ){ | 228 | for(auto iter = decoderMap.begin(); iter != decoderMap.end(); ){ |
230 | if (iter->second->isFinished()) | 229 | if (iter->second->isFinished()) |
231 | { | 230 | { |
@@ -235,9 +234,11 @@ void DecoderManager::closeAllFinishedDecoder() | @@ -235,9 +234,11 @@ void DecoderManager::closeAllFinishedDecoder() | ||
235 | } | 234 | } |
236 | else | 235 | else |
237 | { | 236 | { |
237 | + LOG_INFO("task {} is running", iter->first); | ||
238 | iter++ ; | 238 | iter++ ; |
239 | } | 239 | } |
240 | } | 240 | } |
241 | + m_mutex.unlock(); | ||
241 | } | 242 | } |
242 | 243 | ||
243 | int DecoderManager::count() | 244 | int DecoderManager::count() |