| 81 | } |
| 82 | |
| 83 | void streamfx::util::threadpool::task::wait() |
| 84 | { |
| 85 | std::unique_lock<std::mutex> ul(_lock); |
| 86 | if (!_cancelled && !_completed && !_failed) { |
| 87 | _status_changed.wait(ul, [this]() { return this->is_completed() || this->is_cancelled() || this->has_failed(); }); |
| 88 | } |
| 89 | } |
| 90 | |
| 91 | void streamfx::util::threadpool::task::await_completion() |
| 92 | { |
no test coverage detected