[Bug] Fix CompactionPermitLimiter cv starve bug (#5274)

Fix _permits_cv.wait maybe starve to death bug.
apache · Jan 31, 2021 · 2d70cc5 · 2d70cc5
1 parent b315244
commit 2d70cc5
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/be/src/olap/compaction_permit_limiter.cpp b/be/src/olap/compaction_permit_limiter.cpp
@@ -47,6 +47,7 @@ bool CompactionPermitLimiter::request(int64_t permits) {
 }
 
 void CompactionPermitLimiter::release(int64_t permits) {
+    std::unique_lock<std::mutex> lock(_permits_mutex);
     _used_permits -= permits;
     _permits_cv.notify_one();
     DorisMetrics::instance()->compaction_used_permits->set_value(_used_permits);