| 63 | bool IsMainThread() { return initialized_ && std::this_thread::get_id() == thread_id_; } |
| 64 | |
| 65 | arrow::StopToken GetStopToken() { |
| 66 | if (SignalStopSourceEnabled()) { |
| 67 | return stop_source_->token(); |
| 68 | } else { |
| 69 | return arrow::StopToken::Unstoppable(); |
| 70 | } |
| 71 | } |
| 72 | |
| 73 | bool SignalStopSourceEnabled() { return stop_source_ != nullptr; } |
| 74 |
no test coverage detected