| 1088 | bool IsCurrentExecutor() override { return pool_->IsCurrentExecutor(); } |
| 1089 | |
| 1090 | Status SpawnReal(internal::TaskHints hints, internal::FnOnce<void()> task, |
| 1091 | StopToken stop_token, StopCallback&& stop_callback) override { |
| 1092 | ++spawn_count; |
| 1093 | return pool_->Spawn(hints, std::move(task), std::move(stop_token), |
| 1094 | std::move(stop_callback)); |
| 1095 | } |
| 1096 | |
| 1097 | std::atomic<int> spawn_count{0}; |
| 1098 | internal::Executor* pool_ = internal::GetCpuThreadPool(); |