| 154 | }; |
| 155 | |
| 156 | NPar::TLocalExecutor::TImpl::~TImpl() { |
| 157 | ++QueueSize; |
| 158 | JobQueue.Enqueue(TSingleJob(nullptr, 0)); |
| 159 | HasJob.Signal(); |
| 160 | while (ThreadCount.load()) { |
| 161 | ThreadYield(); |
| 162 | } |
| 163 | } |
| 164 | |
| 165 | void* NPar::TLocalExecutor::TImpl::HostWorkerThread(void* p) { |
| 166 | static constexpr int FAST_ITERATIONS = 200; |
nothing calls this directly
no test coverage detected