| 417 | |
| 418 | template<typename TDatums, typename TQueue> |
| 419 | void QueueBase<TDatums, TQueue>::clear() |
| 420 | { |
| 421 | try |
| 422 | { |
| 423 | const std::lock_guard<std::mutex> lock{mMutex}; |
| 424 | while (!mTQueue.empty()) |
| 425 | mTQueue.pop(); |
| 426 | } |
| 427 | catch (const std::exception& e) |
| 428 | { |
| 429 | error(e.what(), __LINE__, __FUNCTION__, __FILE__); |
| 430 | } |
| 431 | } |
| 432 | |
| 433 | template<typename TDatums, typename TQueue> |
| 434 | unsigned long long QueueBase<TDatums, TQueue>::getMaxSize() const |