| 309 | } |
| 310 | |
| 311 | Status TaskSchedulerImpl::StartScheduling(size_t thread_id, ScheduleImpl schedule_impl, |
| 312 | int num_concurrent_tasks, |
| 313 | bool use_sync_execution) { |
| 314 | schedule_impl_ = std::move(schedule_impl); |
| 315 | #ifdef ARROW_ENABLE_THREADING |
| 316 | use_sync_execution_ = use_sync_execution; |
| 317 | #else |
| 318 | use_sync_execution_ = true; |
| 319 | #endif |
| 320 | num_concurrent_tasks_ = num_concurrent_tasks; |
| 321 | num_tasks_to_schedule_.value += num_concurrent_tasks; |
| 322 | return ScheduleMore(thread_id); |
| 323 | } |
| 324 | |
| 325 | Status TaskSchedulerImpl::ScheduleMore(size_t thread_id, int num_tasks_finished) { |
| 326 | if (aborted_.value.load()) { |
no outgoing calls