* 阻塞式等待弹出 * @return */
| 78 | * @return |
| 79 | */ |
| 80 | std::unique_ptr<T> waitPop() { |
| 81 | CGRAPH_UNIQUE_LOCK lk(mutex_); |
| 82 | cv_.wait(lk, [this] { return !queue_.empty(); }); |
| 83 | std::unique_ptr<T> result = std::move(queue_.front()); |
| 84 | queue_.pop(); |
| 85 | return result; |
| 86 | } |
| 87 | |
| 88 | |
| 89 | /** |
nothing calls this directly
no outgoing calls
no test coverage detected