| 342 | } |
| 343 | |
| 344 | void enqueuePinnedAndUnlock(Task&& task) |
| 345 | { |
| 346 | SkrZoneScopedN("EnqueueTaskWorker"); |
| 347 | auto notify = work.notifyAdded; |
| 348 | work.pinnedTask.push_back(std::move(task)); |
| 349 | work.num++; |
| 350 | skr_mutex_release(&work.mutex); |
| 351 | if (notify) |
| 352 | { |
| 353 | skr_wake_condition_var(&work.added); |
| 354 | } |
| 355 | } |
| 356 | |
| 357 | bool steal(Task& out) |
| 358 | { |
no test coverage detected