ARROW_ENABLE_THREADING
| 227 | |
| 228 | #endif // ARROW_ENABLE_THREADING |
| 229 | void SerialExecutor::Pause() { |
| 230 | // Same comment as SpawnReal above |
| 231 | auto state = state_; |
| 232 | { |
| 233 | std::lock_guard<std::mutex> lk(state->mutex); |
| 234 | state->paused = true; |
| 235 | } |
| 236 | state->wait_for_tasks.notify_one(); |
| 237 | } |
| 238 | |
| 239 | bool SerialExecutor::IsFinished() { |
| 240 | std::lock_guard<std::mutex> lk(state_->mutex); |