| 493 | } |
| 494 | |
| 495 | void wait(event_t event) |
| 496 | { |
| 497 | auto scheduler = scheduler_t::instance(); |
| 498 | SKR_ASSERT(scheduler == nullptr); //must use outside of scheduler |
| 499 | while(!event.done()) |
| 500 | { |
| 501 | event.state->cv.wait(event.state->mutex); |
| 502 | } |
| 503 | } |
| 504 | |
| 505 | scheduler_t::CounterAwaitable::CounterAwaitable(scheduler_t& scheduler, counter_t counter, int workerIdx) |
| 506 | : scheduler(scheduler), counter(std::move(counter)), workerIdx(workerIdx) |