[ARROW-18310] [C++] Use atomic backpressure counter

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 10.0.1, 11.0.0
• Component/s: C++
• Labels: pull-request-available
• External issue URL: https://github.com/apache/arrow/issues/20495
• Assignee: Yaron Gvili
• Reporter: Yaron Gvili
• Created: 11/Nov/22 08:31
• Updated: 11/Jan/23 11:59
• Resolved: 14/Nov/22 16:40

Description

There are a few places in the code (sink_node.cc, source_node.cc, file_base.cc) where the backpressure counter is of type `int32_t`. This prevents `ExecNode::Pause(...)` and  `ExecNode::Resume(...)` from being thread-safe. The proposal is to make these backpressure counters be of type `std::atomic<int32_t>`.

Issue Links

• links to: GitHub Pull Request #14622