| 340 | |
| 341 | template<typename TDatums, typename TQueue> |
| 342 | void QueueBase<TDatums, TQueue>::addPopper() |
| 343 | { |
| 344 | try |
| 345 | { |
| 346 | opLog("", Priority::Low, __LINE__, __FUNCTION__, __FILE__); |
| 347 | const std::lock_guard<std::mutex> lock{mMutex}; |
| 348 | mPoppers++; |
| 349 | updateMaxPoppersPushers(); |
| 350 | } |
| 351 | catch (const std::exception& e) |
| 352 | { |
| 353 | error(e.what(), __LINE__, __FUNCTION__, __FILE__); |
| 354 | } |
| 355 | } |
| 356 | |
| 357 | template<typename TDatums, typename TQueue> |
| 358 | void QueueBase<TDatums, TQueue>::addPusher() |