| 141 | } |
| 142 | |
| 143 | void CPUEngine::submitFunc(std::function<void()>&& f, const Ref<CancellationToken>& ct) |
| 144 | { |
| 145 | { |
| 146 | std::lock_guard<std::mutex> lock(queueMutex); |
| 147 | queue.push({std::move(f), ct}); |
| 148 | } |
| 149 | queueCond.notify_all(); |
| 150 | } |
| 151 | |
| 152 | void CPUEngine::submitHostFunc(std::function<void()>&& f, const Ref<CancellationToken>& ct) |
| 153 | { |
no outgoing calls
no test coverage detected