| 372 | |
| 373 | template<typename TDatums, typename TQueue> |
| 374 | bool QueueBase<TDatums, TQueue>::isRunning() const |
| 375 | { |
| 376 | try |
| 377 | { |
| 378 | const std::lock_guard<std::mutex> lock{mMutex}; |
| 379 | return !(mPushIsStopped && (mPopIsStopped || mTQueue.empty())); |
| 380 | } |
| 381 | catch (const std::exception& e) |
| 382 | { |
| 383 | error(e.what(), __LINE__, __FUNCTION__, __FILE__); |
| 384 | return true; |
| 385 | } |
| 386 | } |
| 387 | |
| 388 | template<typename TDatums, typename TQueue> |
| 389 | bool QueueBase<TDatums, TQueue>::isFull() const |