We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent f549fb9 commit 3d034fbCopy full SHA for 3d034fb
cpp/src/arrow/acero/concurrent_queue_internal.h
@@ -77,7 +77,7 @@ class ConcurrentQueue {
77
78
size_t SizeUnlocked() const { return queue_.size(); }
79
80
- T PopUnlocked(std::unique_lock<std::mutex> &lock) {
+ T PopUnlocked(std::unique_lock<std::mutex>& lock) {
81
cond_.wait(lock, [&] { return !queue_.empty(); });
82
auto item = queue_.front();
83
queue_.pop();
0 commit comments