diff --git a/dbms/src/Common/MPMCQueue.h b/dbms/src/Common/MPMCQueue.h index f82d213690b..e005c363eae 100644 --- a/dbms/src/Common/MPMCQueue.h +++ b/dbms/src/Common/MPMCQueue.h @@ -15,6 +15,7 @@ #pragma once #include +#include #include #include @@ -77,9 +78,7 @@ class MPMCQueue // Cannot to use copy/move constructor, // because MPMCQueue maybe used by different threads. // Copy and move it is dangerous. - MPMCQueue(const MPMCQueue &) = delete; - MPMCQueue(MPMCQueue &&) = delete; - MPMCQueue & operator=(const MPMCQueue &) = delete; + DISALLOW_COPY_AND_MOVE(MPMCQueue); /// Block until: /// 1. Pop succeeds with a valid T: return true.