Stop periodic task thread when all jobs have been removed

apache · Jan 15, 2025 · 7972fdd · 7972fdd
1 parent dcfe45b
commit 7972fdd
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/src/main/cpp/threadutility.cpp b/src/main/cpp/threadutility.cpp
@@ -350,8 +350,6 @@ void ThreadUtility::priv_data::doPeriodicTasks()
 		TimePoint nextOperationTime = currentTime + this->maxDelay;
 		{
 			std::lock_guard<std::recursive_mutex> lock(this->job_mutex);
-			if (this->jobs.empty())
-				break;
 			for (auto& item : this->jobs)
 			{
 				if (this->terminated)
@@ -395,6 +393,8 @@ void ThreadUtility::priv_data::doPeriodicTasks()
 				break;
 			this->jobs.erase(pItem);
 		}
+		if (this->jobs.empty())
+			break;
 
 		std::unique_lock<std::mutex> lock(this->interrupt_mutex);
 		this->interrupt.wait_until(lock, nextOperationTime);