| 74 | |
| 75 | template<typename T> |
| 76 | T BlockingQueue<T>::peek() { |
| 77 | boost::mutex::scoped_lock lock(sync_->mutex_); |
| 78 | |
| 79 | while (queue_.empty()) { |
| 80 | sync_->condition_.wait(lock); |
| 81 | } |
| 82 | |
| 83 | return queue_.front(); |
| 84 | } |
| 85 | |
| 86 | template<typename T> |
| 87 | size_t BlockingQueue<T>::size() const { |
no outgoing calls
no test coverage detected