update

Signed-off-by: fuzhe1989 <fuzhe1989@gmail.com>
pingcap · Mar 11, 2022 · 8e17f3a · 8e17f3a
1 parent a149119
commit 8e17f3a
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/dbms/src/Common/MPMCQueue.h b/dbms/src/Common/MPMCQueue.h
@@ -55,6 +55,7 @@ class MPMCQueue
 
     ~MPMCQueue()
     {
+        std::unique_lock lock(mu);
         for (; read_pos < write_pos; ++read_pos)
             destruct(getObj(read_pos));
     }