Fixed error found by Coverity [#CLICKHOUSE-2].

This commit is contained in:
Alexey Milovidov 2017-09-14 07:24:20 +03:00
parent 9a58e26b8c
commit 5e25c40a26

View File

@ -39,7 +39,7 @@ namespace detail
}
};
/** A very simple thread-safe queue of limited length.
/** A very simple thread-safe queue of limited size.
* If you try to pop an item from an empty queue, the thread is blocked until the queue becomes nonempty.
* If you try to push an element into an overflowed queue, the thread is blocked until space appears in the queue.
*/
@ -47,7 +47,6 @@ template <typename T>
class ConcurrentBoundedQueue
{
private:
size_t max_fill;
std::queue<T> queue;
Poco::FastMutex mutex;
Poco::Semaphore fill_count;