std::queue<T> _dataQueue; void clear() { std::lock_guard<std::mutex> lock(_mutex); std::queue<T> empty; _dataQueue.swap(empty); }