diff --git a/src/decoder/interface/DecoderManager.cpp b/src/decoder/interface/DecoderManager.cpp index d900529..88361a6 100644 --- a/src/decoder/interface/DecoderManager.cpp +++ b/src/decoder/interface/DecoderManager.cpp @@ -224,8 +224,7 @@ void DecoderManager::closeAllDecoder() void DecoderManager::closeAllFinishedDecoder() { - std::lock_guard l(m_mutex); - + m_mutex.lock(); for(auto iter = decoderMap.begin(); iter != decoderMap.end(); ){ if (iter->second->isFinished()) { @@ -235,9 +234,11 @@ void DecoderManager::closeAllFinishedDecoder() } else { + LOG_INFO("task {} is running", iter->first); iter++ ; } } + m_mutex.unlock(); } int DecoderManager::count()