Skip to content

Commit 6da4957

Browse files
Rafał Hibnerzanmato1984
authored andcommitted
Make shutdown flag atomic
1 parent 071c20b commit 6da4957

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

cpp/src/arrow/acero/concurrent_queue_internal.h

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -175,7 +175,7 @@ class BackpressureConcurrentQueue : private ConcurrentQueue<T> {
175175

176176
private:
177177
BackpressureHandler handler_;
178-
bool shutdown_{false};
178+
std::atomic<bool> shutdown_{false};
179179
};
180180

181181
} // namespace arrow::acero

0 commit comments

Comments
 (0)