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