| 25 | |
| 26 | template<typename T> |
| 27 | void BlockingQueue<T>::push(const T& t) { |
| 28 | boost::mutex::scoped_lock lock(sync_->mutex_); |
| 29 | queue_.push(t); |
| 30 | lock.unlock(); |
| 31 | sync_->condition_.notify_one(); |
| 32 | } |
| 33 | |
| 34 | template<typename T> |
| 35 | bool BlockingQueue<T>::try_pop(T* t) { |
no outgoing calls
no test coverage detected